app.post('/myroutehandler/sometask', async (req, res) => {
 
  const storeID = Buffer.from(req.body.message.data, 'base64').toString('utf-8');
  let pageToken = '';
  if (req.body.message.attributes) {
    pageToken = req.body.message.attributes.pageToken;
  }

  const pageSize = 250;
  console.log('StoreID:', storeID);
  const config: StoreConfig = await getConfigById(storeID);

const g = new GoogleApis({});
  g.auth
    .getClient({
      credentials: {
        client_email: config.content_api.credentials.client_email,
        private_key: config.content_api.credentials.private_key.replace(/\\n/g, '\n').trim(),
      },
      scopes: ['https://www.googleapis.com/auth/content'],
    })
    .then(cli => {
      const content = g.content({ version: 'v2', auth: cli });
      
const qryParam: any = { merchantId: config.content_api.merchant_id, maxResults: pageSize, auth: cli };
      if (pageToken) {
        qryParam.pageToken = pageToken;
      }
      content.productstatuses
        .list(qryParam)
        .then(errorList => {
          const nextPageToken = errorList.data.nextPageToken;

          const prmAry = [];
          const upd = fsdb.batch();
          errorList.data.resources.forEach(prod => {
            if (
              prod.itemLevelIssues &&
              prod.itemLevelIssues.some(issue => issue.code === 'policy_violation')
            ) {
              const pid = prod.productId;
              console.log('VIOLATION: ', pid);
              const parsedPid = pid.split(':');
              const issueRef = feedIssuesRef.doc(parsedPid[3]);
              upd.set(issueRef, { pid: parsedPid[3] });
              prmAry.push(deleteFeedItem(pid));
            }
          });
          Promise.all(prmAry)
            .then(results => {
              // console.log('feed updated!');
              upd.commit().then(() => {
                // console.log('issues updated!');
                if (nextPageToken) {
                 
                  const pubsub = new PubSub({ projectId: 'my-project-id' });
                  const dataBuffer = Buffer.from(storeID);
                  const customAttributes = { pageToken: nextPageToken };

                  pubsub
                    .topic('my-special-topic')
                    .publisher()
                    .publish(dataBuffer, customAttributes, (err, messageID) => {
                      res.status(200).end();
                    });
                } else {
                  console.log('no more tokens');
                  res.status(200).end();
                }
              });
            })
            .catch(err => {
              console.log('error in feed update! ', err);
              upd.commit().then(() => {
                console.log('issues updated anyway!');
                res.status(200).end();
              });
            });
        })
        .catch(error => {
          console.error(error.code);
          console.error(error.errors);
          return res.status(200).end();
        });
    });
});