// Copyright Abridged, Inc. 2023,2024. All Rights Reserved. // Node module: @collabland/aws // This file is licensed under the MIT License. // License text available at https://opensource.org/licenses/MIT import {isMain, stringify} from '@collabland/common'; import {OpenSearchServiceClient, loadSecrets} from '../index.js'; async function main() { await loadSecrets(); const client = new OpenSearchServiceClient({}); await client.init(); const countQuery = { index: 'collabland-production-jobs-*', body: { query: { match: { type: 'check-roles-request', }, }, }, }; const count = await client.count(countQuery); console.log('%s', stringify(count)); const query = { index: 'collabland-production-jobs-*', size: 10, body: { aggs: { '2': { date_histogram: { field: 'headers.jobReceivedTime', calendar_interval: '1d', time_zone: 'Asia/Calcutta', min_doc_count: 1, }, aggs: { '3': { terms: { field: 'body.rolesAdded.name.keyword', order: { _count: 'desc', }, size: 20, }, }, }, }, }, size: 0, stored_fields: ['*'], script_fields: {}, docvalue_fields: [ { field: 'body.finish', format: 'date_time', }, { field: 'body.headers.jobReceivedTime', format: 'date_time', }, { field: 'body.start', format: 'date_time', }, { field: 'body.wallets.createdTime', format: 'date_time', }, { field: 'headers.jobReceivedTime', format: 'date_time', }, ], _source: { excludes: [], }, query: { bool: { must: [], filter: [ { match_all: {}, }, { exists: { field: 'body.rolesAdded.id', }, }, { match_phrase: { 'body.communityId': 'DIS#COMM#904119310702772254', }, }, { range: { 'headers.jobReceivedTime': { gte: '2023-05-23T18:53:15.097Z', lte: '2023-06-22T18:53:15.097Z', format: 'strict_date_optional_time', }, }, }, ], should: [], must_not: [], }, }, }, }; const res = await client.search(query); console.log('%s', stringify(res)); await client.stop(); } if (isMain(import.meta.url)) { await main(); } const response = { took: 3701, timed_out: false, _shards: { total: 5108, successful: 5108, skipped: 4867, failed: 0, }, hits: { total: { value: 373, relation: 'eq', }, max_score: null, hits: [], }, aggregations: { '2': { buckets: [ { '3': { doc_count_error_upper_bound: 0, sum_other_doc_count: 0, buckets: [ { key: 'COLLAB Holder 10', doc_count: 5, }, { key: 'DAO Member', doc_count: 5, }, { key: 'DAO Pass', doc_count: 5, }, { key: 'COLLAB Holder 1.4K+', doc_count: 1, }, ], }, key_as_string: '2023-05-24T00:00:00.000+05:30', key: 1684866600000, doc_count: 6, }, { '3': { doc_count_error_upper_bound: 0, sum_other_doc_count: 0, buckets: [ { key: 'COLLAB Holder 10', doc_count: 2, }, { key: 'DAO Member', doc_count: 2, }, { key: 'DAO Pass', doc_count: 2, }, ], }, key_as_string: '2023-05-25T00:00:00.000+05:30', key: 1684953000000, doc_count: 3, }, { '3': { doc_count_error_upper_bound: 0, sum_other_doc_count: 0, buckets: [ { key: 'DAO Member', doc_count: 1, }, { key: 'DAO Pass', doc_count: 1, }, ], }, key_as_string: '2023-05-26T00:00:00.000+05:30', key: 1685039400000, doc_count: 1, }, { '3': { doc_count_error_upper_bound: 0, sum_other_doc_count: 0, buckets: [ { key: 'COLLAB Holder 10', doc_count: 38, }, { key: 'DAO Member', doc_count: 26, }, { key: 'DAO Pass', doc_count: 25, }, { key: 'COLLAB Holder 1.4K+', doc_count: 4, }, { key: 'COLLAB Holder 280K+', doc_count: 1, }, { key: 'Member NFT holder', doc_count: 1, }, ], }, key_as_string: '2023-05-27T00:00:00.000+05:30', key: 1685125800000, doc_count: 46, }, { '3': { doc_count_error_upper_bound: 0, sum_other_doc_count: 0, buckets: [ { key: 'COLLAB Holder 10', doc_count: 4, }, { key: 'DAO Member', doc_count: 4, }, { key: 'DAO Pass', doc_count: 2, }, ], }, key_as_string: '2023-05-28T00:00:00.000+05:30', key: 1685212200000, doc_count: 4, }, { '3': { doc_count_error_upper_bound: 0, sum_other_doc_count: 0, buckets: [ { key: 'COLLAB Holder 10', doc_count: 2, }, { key: 'DAO Member', doc_count: 1, }, { key: 'DAO Pass', doc_count: 1, }, ], }, key_as_string: '2023-05-29T00:00:00.000+05:30', key: 1685298600000, doc_count: 2, }, { '3': { doc_count_error_upper_bound: 0, sum_other_doc_count: 0, buckets: [ { key: 'COLLAB Holder 10', doc_count: 3, }, { key: 'DAO Member', doc_count: 2, }, { key: 'DAO Pass', doc_count: 2, }, ], }, key_as_string: '2023-05-30T00:00:00.000+05:30', key: 1685385000000, doc_count: 3, }, { '3': { doc_count_error_upper_bound: 0, sum_other_doc_count: 0, buckets: [ { key: 'DAO Member', doc_count: 6, }, { key: 'DAO Pass', doc_count: 6, }, { key: 'COLLAB Holder 10', doc_count: 5, }, ], }, key_as_string: '2023-05-31T00:00:00.000+05:30', key: 1685471400000, doc_count: 6, }, { '3': { doc_count_error_upper_bound: 0, sum_other_doc_count: 0, buckets: [ { key: 'DAO Member', doc_count: 3, }, { key: 'DAO Pass', doc_count: 3, }, { key: 'COLLAB Holder 10', doc_count: 2, }, ], }, key_as_string: '2023-06-01T00:00:00.000+05:30', key: 1685557800000, doc_count: 3, }, { '3': { doc_count_error_upper_bound: 0, sum_other_doc_count: 0, buckets: [ { key: 'COLLAB Holder 10', doc_count: 3, }, { key: 'DAO Member', doc_count: 3, }, { key: 'DAO Pass', doc_count: 3, }, ], }, key_as_string: '2023-06-02T00:00:00.000+05:30', key: 1685644200000, doc_count: 4, }, { '3': { doc_count_error_upper_bound: 0, sum_other_doc_count: 0, buckets: [ { key: 'COLLAB Holder 10', doc_count: 2, }, { key: 'DAO Member', doc_count: 2, }, { key: 'DAO Pass', doc_count: 2, }, ], }, key_as_string: '2023-06-04T00:00:00.000+05:30', key: 1685817000000, doc_count: 2, }, { '3': { doc_count_error_upper_bound: 0, sum_other_doc_count: 0, buckets: [ { key: 'COLLAB Holder 10', doc_count: 2, }, { key: 'DAO Member', doc_count: 2, }, { key: 'DAO Pass', doc_count: 2, }, ], }, key_as_string: '2023-06-05T00:00:00.000+05:30', key: 1685903400000, doc_count: 3, }, { '3': { doc_count_error_upper_bound: 0, sum_other_doc_count: 0, buckets: [ { key: 'DAO Member', doc_count: 2, }, { key: 'DAO Pass', doc_count: 2, }, { key: 'COLLAB Holder 10', doc_count: 1, }, ], }, key_as_string: '2023-06-06T00:00:00.000+05:30', key: 1685989800000, doc_count: 2, }, { '3': { doc_count_error_upper_bound: 0, sum_other_doc_count: 0, buckets: [ { key: 'DAO Member', doc_count: 33, }, { key: 'COLLAB Holder 10', doc_count: 32, }, { key: 'DAO Pass', doc_count: 30, }, { key: 'Member NFT holder', doc_count: 2, }, ], }, key_as_string: '2023-06-08T00:00:00.000+05:30', key: 1686162600000, doc_count: 44, }, { '3': { doc_count_error_upper_bound: 0, sum_other_doc_count: 0, buckets: [ { key: 'COLLAB Holder 10', doc_count: 60, }, { key: 'DAO Member', doc_count: 52, }, { key: 'DAO Pass', doc_count: 44, }, { key: 'COLLAB Holder 1.4K+', doc_count: 5, }, { key: 'Member NFT holder', doc_count: 5, }, { key: 'COLLAB Holder 280K+', doc_count: 1, }, ], }, key_as_string: '2023-06-09T00:00:00.000+05:30', key: 1686249000000, doc_count: 81, }, { '3': { doc_count_error_upper_bound: 0, sum_other_doc_count: 0, buckets: [ { key: 'COLLAB Holder 10', doc_count: 7, }, { key: 'DAO Member', doc_count: 6, }, { key: 'DAO Pass', doc_count: 6, }, { key: 'COLLAB Holder 1.4K+', doc_count: 1, }, { key: 'COLLAB Holder 280K+', doc_count: 1, }, { key: 'Member NFT holder', doc_count: 1, }, ], }, key_as_string: '2023-06-10T00:00:00.000+05:30', key: 1686335400000, doc_count: 10, }, { '3': { doc_count_error_upper_bound: 0, sum_other_doc_count: 0, buckets: [ { key: 'DAO Member', doc_count: 8, }, { key: 'DAO Pass', doc_count: 7, }, { key: 'COLLAB Holder 10', doc_count: 6, }, ], }, key_as_string: '2023-06-12T00:00:00.000+05:30', key: 1686508200000, doc_count: 8, }, { '3': { doc_count_error_upper_bound: 0, sum_other_doc_count: 0, buckets: [ { key: 'COLLAB Holder 10', doc_count: 3, }, { key: 'DAO Member', doc_count: 3, }, { key: 'DAO Pass', doc_count: 2, }, { key: 'Member NFT holder', doc_count: 2, }, { key: 'COLLAB Holder 1.4K+', doc_count: 1, }, ], }, key_as_string: '2023-06-13T00:00:00.000+05:30', key: 1686594600000, doc_count: 5, }, { '3': { doc_count_error_upper_bound: 0, sum_other_doc_count: 0, buckets: [ { key: 'COLLAB Holder 10', doc_count: 27, }, { key: 'DAO Member', doc_count: 8, }, { key: 'DAO Pass', doc_count: 6, }, { key: 'COLLAB Holder 1.4K+', doc_count: 2, }, ], }, key_as_string: '2023-06-15T00:00:00.000+05:30', key: 1686767400000, doc_count: 28, }, { '3': { doc_count_error_upper_bound: 0, sum_other_doc_count: 0, buckets: [ { key: 'COLLAB Holder 10', doc_count: 51, }, { key: 'DAO Member', doc_count: 11, }, { key: 'DAO Pass', doc_count: 2, }, ], }, key_as_string: '2023-06-16T00:00:00.000+05:30', key: 1686853800000, doc_count: 51, }, { '3': { doc_count_error_upper_bound: 0, sum_other_doc_count: 0, buckets: [ { key: 'COLLAB Holder 10', doc_count: 13, }, { key: 'DAO Member', doc_count: 2, }, { key: 'DAO Pass', doc_count: 1, }, { key: 'Member NFT holder', doc_count: 1, }, ], }, key_as_string: '2023-06-17T00:00:00.000+05:30', key: 1686940200000, doc_count: 13, }, { '3': { doc_count_error_upper_bound: 0, sum_other_doc_count: 0, buckets: [ { key: 'COLLAB Holder 1.4K+', doc_count: 11, }, { key: 'COLLAB Holder 10', doc_count: 3, }, { key: 'DAO Member', doc_count: 2, }, { key: 'DAO Pass', doc_count: 1, }, ], }, key_as_string: '2023-06-18T00:00:00.000+05:30', key: 1687026600000, doc_count: 14, }, { '3': { doc_count_error_upper_bound: 0, sum_other_doc_count: 0, buckets: [ { key: 'COLLAB Holder 1.4K+', doc_count: 14, }, { key: 'COLLAB Holder 10', doc_count: 5, }, { key: 'DAO Pass', doc_count: 3, }, { key: 'Member NFT holder', doc_count: 3, }, { key: 'DAO Member', doc_count: 2, }, ], }, key_as_string: '2023-06-19T00:00:00.000+05:30', key: 1687113000000, doc_count: 20, }, { '3': { doc_count_error_upper_bound: 0, sum_other_doc_count: 0, buckets: [ { key: 'COLLAB Holder 10', doc_count: 4, }, { key: 'COLLAB Holder 1.4K+', doc_count: 2, }, { key: 'DAO Member', doc_count: 2, }, { key: 'DAO Pass', doc_count: 1, }, ], }, key_as_string: '2023-06-20T00:00:00.000+05:30', key: 1687199400000, doc_count: 5, }, { '3': { doc_count_error_upper_bound: 0, sum_other_doc_count: 0, buckets: [ { key: 'COLLAB Holder 10', doc_count: 5, }, { key: 'DAO Member', doc_count: 3, }, { key: 'DAO Pass', doc_count: 3, }, { key: 'COLLAB Holder 1.4K+', doc_count: 1, }, ], }, key_as_string: '2023-06-21T00:00:00.000+05:30', key: 1687285800000, doc_count: 5, }, { '3': { doc_count_error_upper_bound: 0, sum_other_doc_count: 0, buckets: [ { key: 'COLLAB Holder 10', doc_count: 3, }, { key: 'DAO Pass', doc_count: 1, }, { key: 'Member NFT holder', doc_count: 1, }, ], }, key_as_string: '2023-06-22T00:00:00.000+05:30', key: 1687372200000, doc_count: 4, }, ], }, }, };