Appwrite Cloud Function - createSubscriber EndPoint not working

// This is your Appwrite function
// It's executed each time we get a request
export default async ({ req, res, log, error }) => {
  const client = new Client();
  client.setEndpoint(process.env.MY_APPWRITE_ENDPOINT).setProject(process.env.APPWRITE_FUNCTION_PROJECT_ID).setKey(process.env.APPWRITE_API_KEY);
  const functions = new Functions(client);
  const database = new Databases(client);
  const storage = new Storage(client);
  const users = new Users(client);


  const ENDPOINT          = process.env.MY_APPWRITE_ENDPOINT;
  const PROJECT_ID        = process.env.APPWRITE_FUNCTION_PROJECT_ID;
  const API_KEY           = process.env.APPWRITE_API_KEY;
  const DATABASE_ID       = process.env.DATABASE_ID;
  const USERS_ID          = process.env.USERS_ID;
  const SMS_PROVIDER_ID             = process.env.SMS_PROVIDER_ID;
  const EMAIL_PROVIDER_ID           = process.env.EMAIL_PROVIDER_ID;
  const PUSH_PROVIDER_ID            = process.env.PUSH_PROVIDER_ID;

  const GENERAL_TOPIC_ALL             = process.env.GENERAL_TOPIC_ALL;
  const GENERAL_TOPIC_SMS             = process.env.GENERAL_TOPIC_SMS;
  const GENERAL_TOPIC_PUSH            = process.env.GENERAL_TOPIC_PUSH;
  const GENERAL_TOPIC_EMAIL           = process.env.GENERAL_TOPIC_EMAIL;

const data    = JSON.parse(req.bodyRaw);  
  const subscribeType     = data.type;

  try{

    const result = await users.list(
      [Query.limit(500)]
    );
    
    const usersDocList = result.users;

  
    log(`userList ${usersDocList.length}`);
    for(let i=0; i<usersDocList.length; i++){
      let usersList     = usersDocList[i];
      let userId        = usersList.$id;
      let userPhone     = `+${usersList.$id}`;
      let userEmail     = usersList.email;
      let targets       = usersList.targets;

      

        for(let j= 0; j<targets.length; j++){
          if(targets[j].providerType == 'sms'){
            await messaging.createSubscriber(
              GENERAL_TOPIC_SMS, // topicId
              ID.unique(), // subscriberId
              targets[j].$id // targetId
            );
          }
        }
      }
      else if(subscribeType == 'push'){

        for(let j= 0; j<targets.length; j++){
          if(targets[j].providerType == 'push'){
            await messaging.createSubscriber(
              GENERAL_TOPIC_PUSH, // topicId
              ID.unique(), // subscriberId
              targets[j].$id // targetId
            );
          }
        }
      }
      else if(subscribeType == 'all'){

        for(let j= 0; j<targets.length; j++){


          if(targets[j].providerType == 'email'){
            await messaging.createSubscriber(
              GENERAL_TOPIC_ALL, // topicId
              ID.unique(), // subscriberId
              targets[j].$id // targetId
            );
          }

          if(targets[j].providerType == 'sms'){
            await messaging.createSubscriber(
              GENERAL_TOPIC_ALL, // topicId
              ID.unique(), // subscriberId
              targets[j].$id // targetId
            );
          }

          if(targets[j].providerType == 'push'){
            await messaging.createSubscriber(
              GENERAL_TOPIC_ALL, // topicId
              ID.unique(), // subscriberId
              targets[j].$id // targetId
            );
          }
        }
      }
    }

  
  }catch(appwriteErrors){

    error(appwriteErrors);
  }
  


  return res.send({"data": "end like this"});
  

};```

        log(`Email sub`);

        log(`UserId ${userId}`);
        log(`UserId ${userEmail}`);
        log(`targets ${targets.length}`);
        for(let j= 0; j<targets.length; j++){
          log(`email ${j}`);
          if(targets[j].providerType == 'email'){
            log(`started`);
            try{

              await messaging.createSubscriber(
                GENERAL_TOPIC_EMAIL, // topicId
                ID.unique(), // subscriberId
                targets[j].$id // targetId
              );
            }catch(creatingError){
              error({
                "error":creatingError,
                "depth":'creatingErrorEmail'
              });
            }
            log(`done`);
          }
        }
      }```