From 9ae53f1d51e67be1b099fddc8416193ae210de06 Mon Sep 17 00:00:00 2001 From: "CHIEFSOFT\\ameye" Date: Mon, 9 Sep 2024 19:24:22 -0400 Subject: [PATCH] Site help --- wrenchboard/src/shared_tool/site_crons.cc | 19 ++- www-api/app/Helpers/flutterwave_helper.php | 174 +++++++++++++++++++++ www-api/app/Helpers/onesignal_helper.php | 68 ++++++++ 3 files changed, 256 insertions(+), 5 deletions(-) create mode 100644 www-api/app/Helpers/flutterwave_helper.php create mode 100644 www-api/app/Helpers/onesignal_helper.php diff --git a/wrenchboard/src/shared_tool/site_crons.cc b/wrenchboard/src/shared_tool/site_crons.cc index 7ad8e1a0..ec396c56 100644 --- a/wrenchboard/src/shared_tool/site_crons.cc +++ b/wrenchboard/src/shared_tool/site_crons.cc @@ -185,11 +185,20 @@ long ScheduleTransferJobs(CVars in, CVars &out){ } long TestNotificationsJobs(CVars in, CVars &out){ -// if ( load_db_record(out, "SELECT count(uid) AS pending_count FROM money_transfer WHERE status =1 AND completed IS NULL ")> 0){ -// if ( out["pending_count"].Long() > 0 ){ -// alert_email(WRB_CRONJOB_PENDINGSM,out, out); -// } -// } + + CVars xx; + xx["member_uid"] = "70d8ecc4-490f-40e5-9cea-0484f0a9f584"; xx["member_uid"].set_valid( true ); + xx["push_text"] = "Notification test system...Olu"; xx["push_text"].set_valid( true ); + push_ret = BkoSendPush( xx, out); + + xx["member_uid"] = "d96607ee-37ac-458f-a57d-7f2027a9ba11"; xx["member_uid"].set_valid( true ); + xx["push_text"] = "Notification test system...Obax"; xx["push_text"].set_valid( true ); + push_ret = BkoSendPush( xx, out); + + xx["member_uid"] = "52cee358-759f-42f5-8cfb-d3f77b323c1a"; xx["member_uid"].set_valid( true ); + xx["push_text"] = "Notification test system...Toks"; xx["push_text"].set_valid( true ); + push_ret = BkoSendPush( xx, out); + return 0; } diff --git a/www-api/app/Helpers/flutterwave_helper.php b/www-api/app/Helpers/flutterwave_helper.php new file mode 100644 index 00000000..14e933ef --- /dev/null +++ b/www-api/app/Helpers/flutterwave_helper.php @@ -0,0 +1,174 @@ + $in['id'], + "account_bank" => $in['bank_code'], + "account_number" => $in['account_no'], + "amount" => $in['amount'], + "narration" => $in['narration'], + "currency" => "NGN", + "reference" => $reference, + "debit_currency" => "NGN" + )); + + curl_setopt($ch, CURLOPT_URL,"http://host.docker.internal:9086/create"); + // curl_setopt($ch, CURLOPT_POST, 1); + curl_setopt($ch, CURLOPT_POSTFIELDS, $payload); + curl_setopt($ch, CURLOPT_HTTPHEADER, array('Content-Type:application/json')); + + // Receive server response ... + curl_setopt($ch, CURLOPT_RETURNTRANSFER, true); + + $result = curl_exec($ch); + + curl_close ($ch); + + $data = json_decode($result, true); + + //var_dump( $data); + //exit; + /* + {"account_bank":"044","account_number":"0690000031","amount":"123.00","narration":"Transfer from Olusesan Amey + ses66181+1@gmail.com","currency":"NGN","reference":"120-0-97165300 1652605656","debit_currency":"NGN"} //// {"status":200,"statusText":"OK","data":{"status":"success","message":"Transfer Queued Successfully","data":{"id":345332,"account_number":"0690000031","bank_code":"044","full_name":"Forrest Green","created_at":"2022-05-15T09:07:37.000Z","currency":"NGN","debit_currency":"NGN","amount":123,"fee":10.75,"status":"NEW","reference":"120-0-97165300 1652605656","meta":null,"narration":"Transfer from Olusesan Amey + ses66181+1@gmail.com","complete_message":"","requires_approval":0,"is_approved":1,"bank_name":"ACCESS BANK NIGERIA"}}} + */ + + // Further processing ... + if ($data!=null && is_array($data)) { + if (array_key_exists('status',$data) && $data['status']=='success') { + $out['result'] = 0; // OK + $out['status'] = 'Transfer successful'; + if (array_key_exists('message',$data) && $data['message']!='') { + $out['status'].= ': '.$data['message']; + } + } else { + $out['result'] = -3; + $out['status'] = 'failure'; + if (array_key_exists('status',$data) && $data['status']!='') { + $out['status'] = (is_array($data['status'])?implode("
\n",$data['status']):$data['status']); + } + if (array_key_exists('message',$data) && $data['message']!='') { + $out['status'].= ': '.(is_array($data['message'])?implode("
\n",$data['message']):$data['message']); + } + if (array_key_exists('details',$data) && $data['details']!='') { + $out['status'].= ': 
'.json_encode($data['details'],JSON_PRETTY_PRINT).'
'; + //$out['status'].= ': '.(is_array($data['details'])?implode("
\n",$data['details']):$data['details']); + } + if (array_key_exists('data',$data) && is_array($data['data']) + && array_key_exists('message',$data['data']) && $data['data']['message']!='') { + $out['status'].= ': '.$data['data']['message']; + } + if (array_key_exists('data',$data) && is_array($data['data']) + && array_key_exists('data',$data['data']) && is_array($data['data']['data']) + && array_key_exists('complete_message',$data['data']['data']) && $data['data']['data']['complete_message']!='') { + $out['status'].= ': '.$data['data']['data']['complete_message']; + } + } + } else { + $out['result'] = -2; + $out['status'] = 'Invalid service response: ' . $result; + } + // Cannot POST /api/create + + $out['response'] = $result; + + return $out; + } +} + +if ( ! function_exists('flutterwave_api_check')) +{ + function flutterwave_api_check($in) + { + $out = array(); + $out['status'] = 'Unhandled error'; + $out['result'] = -1; + + $ch = curl_init(); + + $url = "http://host.docker.internal:9086/status/".$in['id']; + + $curl = curl_init($url); + curl_setopt($curl, CURLOPT_URL, $url); + curl_setopt($curl, CURLOPT_RETURNTRANSFER, true); + + $result = curl_exec($curl); + + curl_close($curl); + + //var_dump($result); + /* + string(592) "{"status":200,"statusText":"OK","data":{"status":"success","message":"Transfer fetched","data":{"id":348032,"account_number":"0690000031","bank_code":"044","full_name":"Forrest Green","created_at":"2022-06-05T04:22:49.000Z","currency":"NGN","debit_currency":"NGN","amount":123,"fee":10.75,"status":"FAILED","reference":"120-0-37263200 1654402969","meta":null,"narration":"Transfer from Olusesan Amey + ses66181+1@gmail.com","approver":null,"complete_message":"DISBURSE FAILED: Insufficient funds in customer balance","requires_approval":0,"is_approved":1,"bank_name":"ACCESS BANK NIGERIA"}}}" + */ + + $data = json_decode($result, true); + + // Further processing ... + if ($data!=null && is_array($data)) { + if (array_key_exists('status',$data) && $data['status']=='200') { + if (array_key_exists('data',$data) && is_array($data['data'])) { + $raw = $data['data']; + if (array_key_exists('status',$raw) && $raw['status']=='success') { + $out['result'] = 0; // OK + $out['status'] = $raw['message']; + if (array_key_exists('data',$raw) && is_array($raw['data'])) { + $out['status'].= ': '.$raw['data']['complete_message']; + } else { + $out['status'].= ': No transfer data found -> ' . json_encode($raw); + } + } else { + $out['result'] = -5; + $out['status'] = 'Flutterwave response failure: ' . json_encode($raw); + } + } else { + $out['result'] = -4; + $out['status'] = 'Missing flutterwave response: ' . $result; + } + } else { + // Error response + $out['result'] = -3; + if (array_key_exists('status',$data)) { + $out['status'] = $data['status']; + } else { + $out['status'] = 'Missing starus response: ' . $result; + } + } + } else { + $out['result'] = -2; + $out['status'] = 'Invalid service response: ' . $result; + } + + return $out; + } +} diff --git a/www-api/app/Helpers/onesignal_helper.php b/www-api/app/Helpers/onesignal_helper.php new file mode 100644 index 00000000..d05560c2 --- /dev/null +++ b/www-api/app/Helpers/onesignal_helper.php @@ -0,0 +1,68 @@ + $OneSignalApp, + 'included_segments' => array($in["included_segments"]), // "Subscribed Users", + /* 'data' => array("foo" => "bar"), */ + 'contents' => array( + "en" => $in["message"] + ) + ); + + $fields = json_encode($fields); + //print("\nJSON sent:\n"); + //print($fields); + + + $ch = curl_init(); + curl_setopt($ch, CURLOPT_URL, $OneSignalUrl); + curl_setopt($ch, CURLOPT_HTTPHEADER, array( + 'Accept: application/json', + 'Content-Type: application/json; charset=utf-8', + 'Authorization: Basic "'.$OneSignalKey."'")); + curl_setopt($ch, CURLOPT_RETURNTRANSFER, TRUE); + curl_setopt($ch, CURLOPT_HEADER, FALSE); + curl_setopt($ch, CURLOPT_POST, TRUE); + curl_setopt($ch, CURLOPT_POSTFIELDS, $fields); + curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, FALSE); + + $response = curl_exec($ch); + curl_close($ch); + + //echo "
${response}
"; + + if ($response != "") { + $data = json_decode($response,true); + if (is_array($data) && count($data)>0) { + $out["data"] = $data; + if (array_key_exists("recipients",$data) && $data["recipients"] > 0 + && (!array_key_exists("errors",$data) || count($data["errors"]) < 1)) { + $out["status"] = "Sent to ".$data["recipients"]." recipeint(s)"; + $out["result"] = 1; + } else { + $out["status"] = "errors: ". + (array_key_exists("errors",$data)?json_encode($data["errors"]):"unknown error"); + } + } else { + $out["status"] = "Invalid OneSignal API response: ".$response; + } + } else { + $out["status"] = "Missing OneSignal API response"; + } + return $out; + } +}