Skip to content

Commit a561db5

Browse files
committed
Fixing bug on sources
1 parent 48f1c7d commit a561db5

File tree

2 files changed

+14
-14
lines changed

2 files changed

+14
-14
lines changed

components/frontapp/sources/new-conversation-created/new-conversation-created.mjs

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -27,14 +27,14 @@ export default {
2727
ts: conversation.created_at * 1000,
2828
};
2929
},
30-
hooks: {
31-
async deploy() {
32-
await this.startEvent(25, (item, lastTs) => item.created_at > lastTs);
33-
},
34-
},
35-
async run() {
36-
await this.startEvent(0, (item, lastTs) => item.created_at > lastTs);
30+
},
31+
hooks: {
32+
async deploy() {
33+
await this.startEvent(25, (item, lastTs) => item.created_at > lastTs);
3734
},
3835
},
36+
async run() {
37+
await this.startEvent(0, (item, lastTs) => item.created_at > lastTs);
38+
},
3939
sampleEmit,
4040
};

components/frontapp/sources/new-message-template-created/new-message-template-created.mjs

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -27,14 +27,14 @@ export default {
2727
ts: template.created_at * 1000,
2828
};
2929
},
30-
hooks: {
31-
async deploy() {
32-
await this.startEvent(25, (item, lastTs) => item.created_at > lastTs);
33-
},
34-
},
35-
async run() {
36-
await this.startEvent(0, (item, lastTs) => item.created_at > lastTs);
30+
},
31+
hooks: {
32+
async deploy() {
33+
await this.startEvent(25, (item, lastTs) => item.created_at > lastTs);
3734
},
3835
},
36+
async run() {
37+
await this.startEvent(0, (item, lastTs) => item.created_at > lastTs);
38+
},
3939
sampleEmit,
4040
};

0 commit comments

Comments
 (0)