diff --git a/app/api/UsersApi.php b/app/api/UsersApi.php
index cfc3f0e..19a54f2 100644
--- a/app/api/UsersApi.php
+++ b/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'];
-		$subscriptionUserId = $this->input['user_id'];
-		NotificationManager::addSubscriber($subscriptionUserId, $subscriptionToken);
+		NotificationManager::addSubscriber($userId, $this->input['pushtoken']);
 		$this->response(['value'=>'OK']);
 	}
 }
diff --git a/app/models/managers/AuthManager.php b/app/models/managers/AuthManager.php
index a03ea4d..16102c7 100644
--- a/app/models/managers/AuthManager.php
+++ b/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;
+	}
 }