|
@@ -45,6 +45,22 @@ module.exports = { |
|
|
await strapi.api["session-data"].services[ |
|
|
await strapi.api["session-data"].services[ |
|
|
"session-data" |
|
|
"session-data" |
|
|
].delete({ id }); |
|
|
].delete({ id }); |
|
|
|
|
|
const messages = await strapi.api.message.services.message.find( |
|
|
|
|
|
{ |
|
|
|
|
|
_sort: "session_datum_key:desc", |
|
|
|
|
|
state: "QUEUE", |
|
|
|
|
|
session_datum_key: i["id"], |
|
|
|
|
|
} |
|
|
|
|
|
); |
|
|
|
|
|
for (const message of messages) { |
|
|
|
|
|
await strapi.api.message.services.message.update( |
|
|
|
|
|
{ id: message.id }, |
|
|
|
|
|
{ |
|
|
|
|
|
state: "ERROR", |
|
|
|
|
|
keterangan: "sessions no longer valid", |
|
|
|
|
|
} |
|
|
|
|
|
); |
|
|
|
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
@@ -95,14 +111,17 @@ module.exports = { |
|
|
} else { |
|
|
} else { |
|
|
await strapi.api.message.services.message.update( |
|
|
await strapi.api.message.services.message.update( |
|
|
{ id: message.id }, |
|
|
{ id: message.id }, |
|
|
{ state: "ERROR" } |
|
|
|
|
|
|
|
|
{ |
|
|
|
|
|
state: "ERROR", |
|
|
|
|
|
keterangan: send["DATA"], |
|
|
|
|
|
} |
|
|
); |
|
|
); |
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|
} catch (e) { |
|
|
} catch (e) { |
|
|
await strapi.api.message.services.message.update( |
|
|
await strapi.api.message.services.message.update( |
|
|
{ id: message.id }, |
|
|
{ id: message.id }, |
|
|
{ state: "ERROR" } |
|
|
|
|
|
|
|
|
{ state: "ERROR", keterangan: e.message } |
|
|
); |
|
|
); |
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|