ctautomailhooks/lib/Hooks/UserHooks.php
2021-01-23 23:40:17 -08:00

135 lines
5.2 KiB
PHP

<?php
namespace OCA\CTAutoMailHooks\Hooks;
use OCP\ILogger;
use OCP\IUserManager;
use OCA\CTAutoMailHooks\Config;
class UserHooks {
private $logger;
private $config;
private $userManager;
private $logContext = ['app' => 'ct_auto_mail_hooks'];
public function __construct(
ILogger $logger, Config $config, IUserManager $userManager) {
$this->logger = $logger;
$this->config = $config;
$this->userManager = $userManager;
}
public function register() {
$this->userManager->listen(
'\OC\User', 'postCreateUser',$this->createUserCB());
$this->userManager->listen(
'\OC\User', 'preDelete', $this->deleteUserCB());
}
private function createUserCB() {
return function (\OC\User\User $user, string $password) {
$uid = $user->getUID();
$name = $user->getDisplayName();
$email_suffix = $this->config->getEmailAddressSuffix();
$quota = $this->config->getEmailQuotaMB();
$newuser = array(
'userid' => $uid,
'password' => $password,
'name' => $name,
'email' => $uid . $email_suffix,
'quota' => $quota // in MB
);
$this->logger->warning("newuser:". print_r($newuser,1));
if($this->createEmailAccount($newuser)) {
$this->logger->warning(
"Automatically created mail account for uid " . $uid
. " with e-mail address \"" . $newuser["email"]
. " e-mail address suffix was \"". $email_suffix . "\"."
, $this->logContext);
}
else {
$this->logger->error(
"Error creating mail account OR mail folders for uid "
. $uid);
}
};
}
private function deleteUserCB() {
return function (\OC\User\User $user) {
$uid = $user->getUID();
$email_suffix = $this->config->getEmailAddressSuffix();
$email = $uid . $email_suffix;
$user_data = array('email' => $email);
$this->logger->warning("user_data:". print_r($user_data,1));
if($this->deleteEmailAccount($user_data))
$this->logger->warning(
"Deleted mail account: " . $email, $this->logContext);
else $this->logger->error("Error deleting mail account" . $uid);
};
}
private function createImapFolders($newuser) {
$server = 'mail.glesys.se';
$email = $newuser['email'];
$passw = $newuser['password'];
$folders = array('Sent', 'Drafts', 'Trash', 'Junk', 'Archive');
$mbox = \imap_open("{" . $server . "}", $email, $passw, OP_HALFOPEN);
if(!$mbox){
$message = "can't connect: " . \imap_last_error();
$this->logger->error($message);
return false;
}
foreach ($folders as $folder) {
if (! @\imap_createmailbox( $mbox,
\imap_utf7_encode("{" . $server . "}INBOX." . $folder ))) {
$message = 'Error creating ' . $folder . ' folder.';
$this->logger->error($message);
return false;
}
}
\imap_close($mbox);
return true;
}
private function createEmailAccount($newuser) {
$keys = $this->config->getGlesysKeys();
$this->logger->debug("glesysKeys:" . $keys);
$fields = array(
'emailaccount' => $newuser['email'],
'password' => $newuser['password'],
'quota' => 1000
);
$this->logger->warning("fields:" . print_r($fields, 1));
$query = http_build_query($fields);
$ch = curl_init();
curl_setopt($ch, CURLOPT_URL,
'https://api.glesys.com/email/createaccount/');
curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
curl_setopt($ch, CURLOPT_POST, 1);
curl_setopt($ch, CURLOPT_USERPWD, $keys);
curl_setopt($ch, CURLOPT_POSTFIELDS, $query);
$result = curl_exec($ch);
if (curl_errno($ch)) {
$message = 'Error:' . curl_error($ch);
$this->logger->error($message);
return false;
}
curl_close($ch);
$xml = simplexml_load_string($result);
$code = $xml->status->code;
$this->logger->warning("xml status text:" . $xml->status->text);
if ($code == 200) return $this->createImapFolders($newuser);
return false;
}
private function deleteEmailAccount($user){
$ch = curl_init();
$keys = $this->config->getGlesysKeys();
$this->logger->debug("glesysKeys:" . $keys);
curl_setopt($ch, CURLOPT_URL, 'https://api.glesys.com/email/delete/');
curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
curl_setopt($ch, CURLOPT_POSTFIELDS, "email=" . $user["email"]);
curl_setopt($ch, CURLOPT_POST, 1);
curl_setopt($ch, CURLOPT_USERPWD, $keys);
$result = curl_exec($ch);
if (curl_errno($ch)) {
$message = 'Error:' . curl_error($ch);
$this->logger->error($message);
return false;
}
curl_close($ch);
return true;
}
}