davidroman0o / moleculer-cron Goto Github PK

crons: [
 {
	name: "Cron-Job",
	cronTime: process.env.CRON_TIMER,
	onTick: function() {
	 this.getLocalService("RefreshToken").actions.mainAction();
	},
	manualStart: false
 },
],
actions: {
 mainAction: {
	async handler() {
          const result = this.myMethod();
	  // do something with result;
	},
 },
},
methods: {
  myMethod() {
   return "something"; 
  }
}

CronJob.prototype.setTime = function(time) {
  if (!(time instanceof CronTime)) throw new Error('time must be an instance of CronTime.');
  this.stop();
  this.cronTime = time;
};

import { Service, ServiceBroker, ServiceSchema } from 'moleculer'; -- 
import Cron from 'moleculer-cron';

export default class SchedulerService extends Service
{
    public constructor(public broker: ServiceBroker, schema: ServiceSchema<{}> = {})
    {
        super(broker);
        this.parseServiceSchema({
            name: 'scheduler',
            version: 1,
            mixins: [Cron],
            settings: {
                rest: '/',
                $noServiceNamePrefix: false,
                $noVersionPrefix: true,
            },
            hooks: {
                before: {

                },
            },
            actions: {
                // actions
            },
            methods: {
                // nothing
            },
            dependencies: [
                'config',
            ],
            started: async () =>
            {
            },
            crons: [
                {
                    name: 'AdapterConfigScheduler',
                    cronTime: '*/10 * * * *',
                    onTick: async () =>
                    {
                        console.log('ticked.............'); // PRINTING ONCE
                        await broker.call('config.networkAdapterConfig', {}, { parentCtx: null });
                    },
                    runOnInit: async () =>
                    {
                        console.log('runOnInit.............'); // NOT PRINTING
                        await broker.call('config.networkAdapterConfig', {}, { parentCtx: null });
                    },
                    timeZone: 'America/Los_Angeles',
                },
            ],
        });
    }
}

created() {
		this.$crons = [];
		if (this.schema.crons) {
			// `cron` changed their way of creating crons, so now it's a function that will proxy the instanciation
			this.$crons = this.schema.crons.map((job) => {
console.log('in create.') // PRINTS
				var instance_job = () => {
console.log('in create.') // NOT PRINTS, SERVER FREEZES
					// cronTime, onTick, onComplete, start, timeZone, context, runOnInit, utcOffset, unrefTimeout
					var cronjob = new cron.CronJob(
						job.cronTime, // cronTime
						job.onTick || (_ => {}), // onTick
						job.onComplete || (_ => {}), // onComplete
						job.manualStart || false, // start
						job.timeZone, // timeZone
						Object.assign(
							this.broker,
							{
								getJob: this.getJob,
							}
						), // context
						job.runOnInit || (_ => {}), // runOnInit
						job.utcOffset || null, // utcOffset
						job.unrefTimeout || null, // unrefTimeout
					)
					cronjob.manualStart = job.manualStart || false
					cronjob.name = job.name || this.makeid(20);
					return cronjob;
				};
				
				return instance_job;
			});
		}
		return this.Promise.resolve();
	},