mirror of
https://gitlab.com/t6353/sharee.bike.git
synced 2024-06-02 05:46:33 +02:00
201 lines
6.3 KiB
Perl
201 lines
6.3 KiB
Perl
package Mod::APIshareeio;
|
|
#
|
|
# SPDX-License-Identifier: AGPL-3.0-or-later
|
|
# Copyright (c) Rainer Gümpelein, TeilRad GmbH
|
|
#
|
|
use warnings;
|
|
use strict;
|
|
use Exporter;
|
|
our @ISA = qw (Exporter);
|
|
|
|
use POSIX;
|
|
use CGI;
|
|
use Apache2::Const -compile => qw(OK );
|
|
use JSON;
|
|
use Scalar::Util qw(looks_like_number);
|
|
use Config::General;
|
|
|
|
use Lib::Config;
|
|
use Mod::DBtank;
|
|
use Mod::Basework;
|
|
use Mod::Shareework;
|
|
use Mod::APIfunc;
|
|
use Data::Dumper;
|
|
|
|
sub handler {
|
|
my ($r) = @_;
|
|
my $q = new CGI;
|
|
my $netloc = $q->url(-base=>1);
|
|
$q->import_names('R');
|
|
my $json = JSON->new->allow_nonref;
|
|
my $cf = new Config;
|
|
my $dbt = new DBtank;
|
|
my $bw = new Basework;
|
|
my $tk = new Shareework;
|
|
my $apif = new APIfunc;
|
|
|
|
my $dbh = "";
|
|
my %varenv = $cf->envonline();
|
|
my $oprefix = $dbt->{operator}->{$varenv{dbname}}->{oprefix};
|
|
my $now_dt = strftime "%Y-%m-%d %H:%M:%S", localtime;
|
|
my @keywords = $q->param;
|
|
my $user_agent = $q->user_agent();
|
|
my $aowner = 168;
|
|
my $debug=1;
|
|
my $dbh = "";
|
|
my $api_file = "/var/www/copri4/shareeconf/apikeys.cfg";
|
|
my $aconf = Config::General->new($api_file);
|
|
my %apikeyconf = $aconf->getall;
|
|
|
|
my %headers = map { $_ => $q->http($_) } $q->http();
|
|
$bw->log("APIshareeio request:\n--> user-agent '$user_agent' ",$q,"");
|
|
$bw->log("headers:",\%headers,"");
|
|
|
|
#for my $header ( keys %headers ) {
|
|
# print "$header: $headers{$header}\n";
|
|
#}
|
|
|
|
print $q->header(-type => "application/json", -charset => "utf-8", -'Access-Control-Allow-Origin' => "*");
|
|
|
|
open(FILE,">>$varenv{logdir}/APIshareeio.log") if($debug);
|
|
print FILE "\n*** $now_dt user-agent: '$user_agent' to syshost: $varenv{syshost}\n" if($debug);
|
|
print FILE "<=== DUMP query\n " . Dumper($q) . "\n" if($debug);
|
|
print FILE "<=== DUMP postdata:\n " . Dumper($q->param('POSTDATA')) . "\n" if($debug);
|
|
|
|
|
|
my $response = {
|
|
response_state => "OK, nothing todo",
|
|
};
|
|
|
|
my $http_sharee_api_key = $headers{HTTP_SHAREE_API_KEY} || $R::HTTP_SHAREE_API_KEY || "";
|
|
if(!$apikeyconf{shareeio}->{sharee_api_key} || !$http_sharee_api_key || $apikeyconf{shareeio}->{sharee_api_key} ne $http_sharee_api_key){
|
|
$response->{response_state} = "Failure: access denied, api-key doesn't match";
|
|
$bw->log("Failure: access denied, api-key doesn't match",$q,"");
|
|
my $jrout = $json->pretty->encode({shareeio => $response});
|
|
print $jrout;
|
|
return Apache2::Const::OK;
|
|
exit 0;
|
|
}
|
|
|
|
foreach(@keywords){
|
|
if(length($_) > 40 || length($q->param($_)) > 400){
|
|
$response->{response_state} = "Failure 9000: amount of characters in $_ exceeds";
|
|
$bw->log("Failure 9000: amount of characters in $_ exceeds",$q,"");
|
|
my $jrout = $json->pretty->encode({shareeio => $response});
|
|
print $jrout;
|
|
return Apache2::Const::OK;
|
|
exit 0;
|
|
}
|
|
}
|
|
|
|
|
|
#sig booking_update
|
|
sig_booking_update();# sig json post
|
|
|
|
#sig json api
|
|
sub sig_booking_update {
|
|
|
|
my $jrout = "seems to be not valid";
|
|
|
|
#sig using POST JSON
|
|
my $POSTDATA = $q->param('POSTDATA');
|
|
|
|
#REST methode only used for easy testing
|
|
if($R::request && $R::request eq "booking_update"){
|
|
my $rentalId = $q->escapeHTML($R::rentalId) || "";
|
|
my %POSTDATA_hash = (
|
|
"event"=>"RENTAL_END",
|
|
"data"=>{
|
|
"bikeId"=>"test16b5-0522-43da-ab66-477744a731a3",
|
|
"lockStatus"=>"unlocked",
|
|
"rentalId"=>"$rentalId",
|
|
"reservationState"=>"",
|
|
"startTime"=>"2022-06-06T15:00:18.045Z",
|
|
"endTime"=>"2022-06-06T15:01:43.118Z",
|
|
"distance"=>1000
|
|
}
|
|
);
|
|
$POSTDATA = encode_json(\%POSTDATA_hash);
|
|
print FILE "<=== DUMP POSTDATA_hash:\n " . Dumper(\%POSTDATA_hash) . "\n" if($debug);
|
|
}
|
|
eval {
|
|
my $response_in = {};
|
|
$response_in = decode_json($POSTDATA) if($POSTDATA);
|
|
|
|
if($response_in->{event} && $response_in->{event} eq "RENTAL_END"){
|
|
|
|
my $rentalId = $q->escapeHTML($response_in->{data}->{rentalId}) || "";
|
|
my $rows = 0;
|
|
my $booking_values = {};
|
|
|
|
if($rentalId){
|
|
|
|
my $ctpos = {};
|
|
my $booking_pos = {
|
|
table => "contenttranspos",
|
|
fetch => "one",
|
|
txt11 => "$rentalId",
|
|
int10 => "IN::('2','3')",
|
|
#ca_id => "$authraw->{c_id}",#sig doesn't know uid
|
|
};
|
|
$ctpos = $dbt->fetch_tablerecord($dbh,$booking_pos);
|
|
|
|
my $distance = 0;
|
|
$distance = $response_in->{data}->{distance} / 1000 if(looks_like_number($response_in->{data}->{distance}) && $response_in->{data}->{distance} > 0);
|
|
$distance = sprintf('%.2f',$distance);
|
|
if(ref($ctpos) eq "HASH" && $ctpos->{txt22} && $ctpos->{txt11}){
|
|
my $sig_book = {
|
|
bikeId => $ctpos->{txt22},
|
|
rentalId => $ctpos->{txt11},
|
|
reservationId => "",
|
|
station_lock_state => "3",#addition state in context to get state=returned for miniquery
|
|
distance => $distance,
|
|
};
|
|
|
|
my $authraw = { c_id => "" };
|
|
$authraw->{c_id} = $ctpos->{ca_id} if($ctpos->{ca_id});
|
|
$q->param(-name=>'bike',-value=>"$ctpos->{ct_name}") if($ctpos->{ct_name});
|
|
$q->param(-name=>'state',-value=>"available");
|
|
$q->param(-name=>'lock_state',-value=>"locked");
|
|
($rows, $booking_values) = $apif->booking_update($q,\%varenv,$authraw,$aowner,$sig_book) if($authraw->{c_id});
|
|
|
|
#response is for sig json after rental-end
|
|
delete $booking_values->{geo_distance};
|
|
delete $booking_values->{response_state};
|
|
delete $booking_values->{response_text};
|
|
$booking_values->{bikeId} = $sig_book->{bikeId};
|
|
$booking_values->{rentalId} = $sig_book->{rentalId};
|
|
$response = {%$response, %$booking_values};
|
|
}else{
|
|
$response->{response_state} = "Failure: there is no rental with rentalID=$rentalId";
|
|
}
|
|
|
|
}else{
|
|
$response->{response_state} = "Failure: no rentalId defined";
|
|
}
|
|
|
|
}#end event
|
|
};#end eval
|
|
if ($@){
|
|
print FILE "failure! can not decode POST json, POSTDATA:\n" . Dumper($q->param('POSTDATA')) . "\n" if($debug);
|
|
#warn $@;
|
|
print FILE "warn:" . $@ . "\n" if($debug);
|
|
}
|
|
|
|
}#end sig json booking_update
|
|
|
|
|
|
#end RESTful ------------------------------------------------------------
|
|
#FINAL JSON response OUTPUT ----------------------------------------------------------
|
|
my $jrout = $json->pretty->encode({shareeio => $response});
|
|
print $jrout;
|
|
|
|
$bw->log("APIjsonserver response by $user_agent mapped aowner:$aowner",$jrout,"");
|
|
#end JSON ----------------------------------------------------------------------------
|
|
|
|
close(FILE) if($debug);
|
|
return Apache2::Const::OK;
|
|
}#end handler
|
|
1;
|
|
|