0
0
Fork 0
mirror of https://github.com/matrix-construct/construct synced 2024-12-27 07:54:05 +01:00
construct/modules/s_fetch.h
2018-11-30 12:59:44 -08:00

60 lines
1.6 KiB
C++

// Matrix Construct
//
// Copyright (C) Matrix Construct Developers, Authors & Contributors
// Copyright (C) 2016-2018 Jason Volk <jason@zemos.net>
//
// Permission to use, copy, modify, and/or distribute this software for any
// purpose with or without fee is hereby granted, provided that the above
// copyright notice and this permission notice is present in all copies. The
// full license for this software is available in the LICENSE file.
// Fetch unit state
namespace ircd::m::fetch
{
struct request;
static void hook_handler(const event &, vm::eval &);
extern hookfn<vm::eval &> hook;
static void init();
static void fini();
}
/// Fetch entity state
struct ircd::m::fetch::request
:m::v1::event
{
using is_transparent = void;
m::room::id::buf room_id;
m::event::id::buf event_id;
unique_buffer<mutable_buffer> _buf;
mutable_buffer buf;
std::set<std::string, std::less<>> attempted;
string_view origin;
time_t started {0};
time_t last {0};
time_t finished {0};
std::exception_ptr eptr;
bool operator()(const request &a, const request &b) const;
bool operator()(const request &a, const string_view &b) const;
bool operator()(const string_view &a, const request &b) const;
void finish();
void retry();
bool handle();
string_view select_origin(const string_view &);
string_view select_random_origin();
void start(m::v1::event::opts &&);
void start();
request(const m::room::id &room_id,
const m::event::id &event_id,
const mutable_buffer & = {});
request() = default;
request(request &&) = delete;
request(const request &) = delete;
};