Refactor readEmails script
[SonOfLokstallBot.git] / common.php
1 <?php declare(strict_types=1);
2
3 require_once('vendor/autoload.php');
4 require_once(__DIR__ . '/config.php');
5
6 use Telegram\Bot\Api;
7
8 function getTelegram() {
9 STATIC $tg;
10 return $tg = $tg ?? new \Telegram\Bot\Api(BOT_TOKEN);
11 }
12
13 function splitBill($amount) {
14 return floor($amount/2);
15 }
16
17 function identity($x) {
18 return $x;
19 }
20
21 function getMessageSender($update) {
22 return PARTICIPANT_IDS[$update->get('message')->get('from')->get('id')];
23 }
24
25 function getMessageSenderDisplayName($update) {
26 return $update->get('message')->get('from')->get('first_name');
27 }
28
29 function canChatWith($update) {
30 return in_array($update->get('message')->get('from')->get('id'), array_keys(PARTICIPANT_IDS));
31 }
32
33 function debug($whatever) {
34 echo '<pre>';
35 print_r($whatever);
36 echo '</pre>';
37 }
38
39 function getInbox($inbox) {
40 STATIC $inboxes;
41
42 if (!isset($inboxes[$inbox])) {
43 $inboxes[$inbox] = imap_open(
44 '{imap.gmail.com:993/debug/imap/ssl/novalidate-cert}' . $inbox,
45 EMAIL,
46 PASSWORD
47 );
48 }
49
50 return $inboxes[$inbox];
51 }
52
53 function getRules() {
54 STATIC $rules;
55 return $rules = $rules ?? require 'rules.php';
56 }
57
58 function getString($identifier, ...$vars) {
59 STATIC $strings;
60 $strings = $strings ?? require 'strings.php';
61
62 return sprintf($strings[$identifier], ...$vars);
63 }
64
65 function formatDate($date) {
66 return $date->format(DATE_FORMAT);
67 }
68
69 const sendToGroupChat = 'sendToGroupChat';
70 function sendToGroupChat(string $message) {
71 return getTelegram()->sendMessage(['chat_id' => CHAT_ID, 'text' => $message]);
72 }
73
74 const generateReminderText = 'generateReminderText';
75 function generateReminderText($message) {
76 return getString('billreminder', REMIND_THRESHOLD, $message['service'], splitBill($message['amount']), formatDate($message['due']));
77 }
78
79 const generateNewBillText = 'generateNewBillText';
80 function generateNewBillText($message) {
81 return getString('newbill', $message['service'], splitBill($message['amount']), formatDate($message['due']));
82 }
83
84 const messageNeedsReminder = 'messageNeedsReminder';
85 function messageNeedsReminder($message) {
86 return $message['due']->diff(new DateTimeImmutable)->d == REMIND_THRESHOLD;
87 }
88
89
90 function(...$fs) {
91 return function($arg) use ($fs) {
92 return array_reduce(array_reverse($fs), function($c, $f) {
93 return $f($c);
94 }, $arg);
95 };
96 }
97
98 function map($callable) {
99 return function($list) use ($callable) {
100 return array_map($callable, $list);
101 };
102 }
103
104 function filter($callable) {
105 return function($list) use ($callable) {
106 return array_filter($list, $callable);
107 };
108 }
109
110 function($a, $b) {
111 return array_merge($a, $b);
112 }
113
114 function getMessagesFromInbox($inbox, array $rules, $unseenOnly = true) {
115 return array_filter(
116 array_map(
117 function($rule, $service) use ($inbox, $unseenOnly) {
118 $emails = imap_search($inbox, ['SEEN ', 'UNSEEN '][$unseenOnly] . $rule['imapQuery'], SE_UID);
119
120 if(!$emails) {
121 return [];
122 }
123
124 $messageTransform = $rule['messageTransform'] ?? 'identity';
125 $dateTransform = $rule['dateTransform'] ?? 'identity';
126
127 $body = imap_fetchbody($inbox, $emails[0], '1', FT_UID);
128 preg_match($rule['regex'], $messageTransform($body), $matches);
129
130 return [
131 'service' => $service,
132 'id' => substr(md5($body), 0, 6),
133 'uid' => $emails[0],
134 'due' => new DateTimeImmutable($dateTransform($matches['due'])),
135 'amount' => $matches['amount']
136 ];
137 },
138 $rules,
139 array_keys($rules)
140 ),
141 function($e) {
142 return !!$e;
143 }
144 );
145 }