Skip to content

Commit db3821e

Browse files
committed
Adjusting isRelevant calls to always emit if ts is falsy
1 parent 78ebe2f commit db3821e

File tree

3 files changed

+5
-5
lines changed

3 files changed

+5
-5
lines changed

components/hubspot/sources/common/common.mjs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -54,7 +54,7 @@ export default {
5454
async processEvents(resources, after) {
5555
let maxTs = after || 0;
5656
for (const result of resources) {
57-
if (await this.isRelevant(result, after)) {
57+
if (!after || await this.isRelevant(result, after)) {
5858
this.emitEvent(result);
5959
const ts = this.getTs(result);
6060
if (ts > maxTs) {
@@ -81,7 +81,7 @@ export default {
8181
for (const result of results) {
8282
const ts = this.getTs(result);
8383
if (!after || ts > after) {
84-
if (await this.isRelevant(result, after, ts)) {
84+
if (!after || await this.isRelevant(result, after, ts)) {
8585
this.emitEvent(result);
8686
}
8787
if (ts > maxTs) {
@@ -124,7 +124,7 @@ export default {
124124
items = results;
125125
}
126126
for (const item of items) {
127-
if (await this.isRelevant(item, after)) {
127+
if (!after || await this.isRelevant(item, after)) {
128128
this.emitEvent(item);
129129
const ts = this.getTs(item);
130130
if (ts > maxTs) {

components/hubspot/sources/new-deal-in-stage/new-deal-in-stage.mjs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -100,7 +100,7 @@ export default {
100100

101101
for (const deal of results.results) {
102102
const ts = await this.getTs(deal);
103-
if (this.isRelevant(ts, after)) {
103+
if (!after || this.isRelevant(ts, after)) {
104104
if (deal.properties.hubspot_owner_id) {
105105
deal.properties.owner = await this.getOwner(
106106
deal.properties.hubspot_owner_id,

components/hubspot/sources/new-form-submission/new-form-submission.mjs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,7 @@ export default {
3636
}
3737

3838
for (const result of results) {
39-
if (await this.isRelevant(result, after)) {
39+
if (!after || await this.isRelevant(result, after)) {
4040
const form = await this.hubspot.getFormDefinition({
4141
formId: params.formId,
4242
});

0 commit comments

Comments
 (0)