highperfocused/nostr-search
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

index improvements

Browse Source
This commit is contained in:
mroxso 2023-10-09 01:04:00 +02:00
parent 780a6bf394
commit 6b29a1da1f
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
main.py
View File

@ -3,6 +3,7 @@ import os
import websockets import websockets
import json import json
from elasticsearch import Elasticsearch from elasticsearch import Elasticsearch
from datetime import datetime
async def relay_websockets(inputWebsocket, kinds, es): async def relay_websockets(inputWebsocket, kinds, es):
while True: while True:
@ -15,7 +16,9 @@ async def relay_websockets(inputWebsocket, kinds, es):
del event[1] del event[1]
print("Sending event " + str(event[1]['id']) + " (kind: "+str(event[1]['kind'])+") to elasticsearch") print("Sending event " + str(event[1]['id']) + " (kind: "+str(event[1]['kind'])+") to elasticsearch")
# send event to elasticsearch # send event to elasticsearch
resp = es.index(index="nostr", id=str(event[1]['id']), document=event[1]) index_name = "nostr-" + datetime.today().strftime('%Y-%m-%d')
event_timestamp = datetime.fromtimestamp(event[1]['created_at'])
resp = es.index(index=index_name, id=str(event[1]['id']), document={**event[1], "@timestamp": event_timestamp})
if(resp['result'] != "created"): if(resp['result'] != "created"):
print("Failed to send event to elasticsearch: "+str(resp)) print("Failed to send event to elasticsearch: "+str(resp))
elif(event[0] == "EOSE"): elif(event[0] == "EOSE"):