Subscribe

app/api/UsersApi.php

@@ -37,10 +37,11 @@ class UsersApi extends ApiController{
 
 	public function subscribe(){
 		//$this->requireAuth();
+		$bearer = $_SERVER['HTTP_AUTHORIZATION'];
+		$authManager = new AuthManager();
+		$userId = $authManager->getUserId($bearer);
 
-		$subscriptionToken = $this->input['token'];
+		NotificationManager::addSubscriber($userId, $this->input['pushtoken']);
-		$subscriptionUserId = $this->input['user_id'];
-		NotificationManager::addSubscriber($subscriptionUserId, $subscriptionToken);
 		$this->response(['value'=>'OK']);
 	}
 }

app/models/managers/AuthManager.php

@@ -61,4 +61,10 @@ class AuthManager {
 		};
 		return false;
 	}
+
+	public function getUserId($bearer){
+		$token = explode(' ',  $bearer)[1];
+		$userid = Db::loadOne('SELECT user_id FROM tokens WHERE token = ? AND expire >= CURRENT_TIMESTAMP AND blocked = 0;', array($token))['user_id'];
+		return $userid;
+	}
 }