forked from forks/microblog.pub
Oops add missing file and reformat
This commit is contained in:
parent
0b3d4251de
commit
9e25cad86c
1 changed files with 61 additions and 0 deletions
61
tasks.py
Normal file
61
tasks.py
Normal file
|
@ -0,0 +1,61 @@
|
||||||
|
import os
|
||||||
|
|
||||||
|
from poussetaches import PousseTaches
|
||||||
|
|
||||||
|
p = PousseTaches(
|
||||||
|
os.getenv("MICROBLOGPUB_POUSSETACHES_HOST", "http://localhost:7991"),
|
||||||
|
os.getenv("MICROBLOGPUB_INTERNAL_HOST", "http://localhost:5000"),
|
||||||
|
)
|
||||||
|
|
||||||
|
|
||||||
|
class Tasks:
|
||||||
|
@staticmethod
|
||||||
|
def cache_object(iri: str) -> None:
|
||||||
|
p.push(iri, "/task/cache_object")
|
||||||
|
|
||||||
|
@staticmethod
|
||||||
|
def cache_actor(iri: str, also_cache_attachments: bool = True) -> None:
|
||||||
|
p.push(
|
||||||
|
{"iri": iri, "also_cache_attachments": also_cache_attachments},
|
||||||
|
"/task/cache_actor",
|
||||||
|
)
|
||||||
|
|
||||||
|
@staticmethod
|
||||||
|
def post_to_remote_inbox(payload: str, recp: str) -> None:
|
||||||
|
p.push({"payload": payload, "to": recp}, "/task/post_to_remote_inbox")
|
||||||
|
|
||||||
|
@staticmethod
|
||||||
|
def forward_activity(iri: str) -> None:
|
||||||
|
p.push(iri, "/task/forward_activity")
|
||||||
|
|
||||||
|
@staticmethod
|
||||||
|
def fetch_og_meta(iri: str) -> None:
|
||||||
|
p.push(iri, "/task/fetch_og_meta")
|
||||||
|
|
||||||
|
@staticmethod
|
||||||
|
def process_new_activity(iri: str) -> None:
|
||||||
|
p.push(iri, "/task/process_new_activity")
|
||||||
|
|
||||||
|
@staticmethod
|
||||||
|
def cache_attachments(iri: str) -> None:
|
||||||
|
p.push(iri, "/task/cache_attachments")
|
||||||
|
|
||||||
|
@staticmethod
|
||||||
|
def finish_post_to_inbox(iri: str) -> None:
|
||||||
|
p.push(iri, "/task/finish_post_to_inbox")
|
||||||
|
|
||||||
|
@staticmethod
|
||||||
|
def finish_post_to_outbox(iri: str) -> None:
|
||||||
|
p.push(iri, "/task/finish_post_to_outbox")
|
||||||
|
|
||||||
|
@staticmethod
|
||||||
|
def update_question_outbox(iri: str, open_for: int) -> None:
|
||||||
|
p.push(
|
||||||
|
iri, "/task/update_question", delay=open_for
|
||||||
|
) # XXX: delay expects minutes
|
||||||
|
|
||||||
|
@staticmethod
|
||||||
|
def fetch_remote_question(iri: str, delay: int) -> None:
|
||||||
|
p.push(
|
||||||
|
iri, "/task/fetch_remote_question", delay=delay
|
||||||
|
) # XXX: delay expects minutes
|
Loading…
Reference in a new issue