Skip to content
Snippets Groups Projects
Select Git revision
  • windows_ci
  • master default
  • cert_pk_id
  • proxy_push_result
  • cnode_put_id
  • update-windows-build
  • proxy
  • resubscribe_on_token_change
  • actions
  • client_mode
  • llhttp
  • search_node_add
  • crypto_aes_gcm_argon2
  • ios_notifications
  • log_fmt
  • v2asio
  • fix-msvc
  • message_split
  • meson
  • build_unify
  • v3.4.0
  • v3.3.1
  • v3.3.1rc1
  • v3.3.1rc2
  • v3.3.0
  • v3.2.0
  • v3.1.11
  • v3.1.10
  • v3.1.9
  • v3.1.8.2
  • v3.1.8.1
  • v3.1.8
  • v3.1.7
  • v3.1.6
  • v3.1.5
  • v3.1.4
  • v3.1.3
  • v3.1.2
  • v3.1
  • v3.0.1
40 results

opendht_c.h

Blame
  • Code owners
    Assign users and groups as approvers for specific file changes. Learn more.
    opendht_c.h 8.76 KiB
    /*
     *  Copyright (C) 2014-2022 Savoir-faire Linux Inc.
     *  Author : Adrien Béraud <adrien.beraud@savoirfairelinux.com>
     *
     *  This program is free software; you can redistribute it and/or modify
     *  it under the terms of the GNU General Public License as published by
     *  the Free Software Foundation; either version 3 of the License, or
     *  (at your option) any later version.
     *
     *  This program is distributed in the hope that it will be useful,
     *  but WITHOUT ANY WARRANTY; without even the implied warranty of
     *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
     *  GNU General Public License for more details.
     *
     *  You should have received a copy of the GNU General Public License
     *  along with this program. If not, see <https://www.gnu.org/licenses/>.
     */
    
    #pragma once
    
    #ifdef __cplusplus
    extern "C" {
    #endif
    
    #include <opendht/def.h>
    #include <sys/socket.h>
    #include <netinet/in.h>
    #include <stdbool.h>
    #include <stdint.h>
    #include <stddef.h>
    
    // Non-owning data view
    struct OPENDHT_C_PUBLIC dht_data_view {
        const uint8_t* data;
        size_t size;
    };
    typedef struct dht_data_view dht_data_view;
    
    // dht::Blob
    struct OPENDHT_C_PUBLIC dht_blob;
    typedef struct dht_blob dht_blob;
    OPENDHT_C_PUBLIC dht_data_view dht_blob_get_data(const dht_blob* data);
    OPENDHT_C_PUBLIC void dht_blob_delete(dht_blob* data);
    
    // dht::InfoHash
    struct OPENDHT_C_PUBLIC dht_infohash { uint8_t d[HASH_LEN]; };
    typedef struct dht_infohash dht_infohash;
    OPENDHT_C_PUBLIC void dht_infohash_zero(dht_infohash* h);
    OPENDHT_C_PUBLIC void dht_infohash_random(dht_infohash* h);
    OPENDHT_C_PUBLIC void dht_infohash_from_hex(dht_infohash* h, const char* dat);
    OPENDHT_C_PUBLIC void dht_infohash_get(dht_infohash* h, const uint8_t* dat, size_t dat_size);
    OPENDHT_C_PUBLIC void dht_infohash_get_from_string(dht_infohash* h, const char* str);
    OPENDHT_C_PUBLIC const char* dht_infohash_print(const dht_infohash* h);
    OPENDHT_C_PUBLIC bool dht_infohash_is_zero(const dht_infohash* h);
    
    // dht::PkId
    struct OPENDHT_C_PUBLIC dht_pkid { uint8_t d[32]; };
    typedef struct dht_pkid dht_pkid;
    OPENDHT_C_PUBLIC const char* dht_pkid_print(const dht_pkid* h);
    
    // dht::crypto::PublicKey
    struct OPENDHT_C_PUBLIC dht_publickey;
    typedef struct dht_publickey dht_publickey;
    OPENDHT_C_PUBLIC dht_publickey* dht_publickey_import(const uint8_t* dat, size_t dat_size);
    OPENDHT_C_PUBLIC void dht_publickey_delete(dht_publickey* pk);
    OPENDHT_C_PUBLIC int dht_publickey_export(const dht_publickey* pk, char* out, size_t* out_size);
    OPENDHT_C_PUBLIC dht_infohash dht_publickey_get_id(const dht_publickey* pk);
    OPENDHT_C_PUBLIC dht_pkid dht_publickey_get_long_id(const dht_publickey* pk);
    OPENDHT_C_PUBLIC bool dht_publickey_check_signature(const dht_publickey* pk, const char* data, size_t data_size, const char* signature, size_t signature_size);
    OPENDHT_C_PUBLIC dht_blob* dht_publickey_encrypt(const dht_publickey* pk, const char* data, size_t data_size);
    
    // dht::crypto::PrivateKey
    struct OPENDHT_C_PUBLIC dht_privatekey;
    typedef struct dht_privatekey dht_privatekey;
    OPENDHT_C_PUBLIC dht_privatekey* dht_privatekey_generate(unsigned key_length_bits);
    OPENDHT_C_PUBLIC dht_privatekey* dht_privatekey_import(const uint8_t* dat, size_t dat_size, const char* password);
    OPENDHT_C_PUBLIC int dht_privatekey_export(const dht_privatekey*, char* out, size_t* out_size, const char* password);
    OPENDHT_C_PUBLIC dht_publickey* dht_privatekey_get_publickey(const dht_privatekey*);
    OPENDHT_C_PUBLIC dht_blob* dht_privatekey_decrypt(const dht_privatekey*, const char* data, size_t data_size);
    OPENDHT_C_PUBLIC void dht_privatekey_delete(dht_privatekey*);
    
    // dht::crypto::Certificate
    struct OPENDHT_C_PUBLIC dht_certificate;
    typedef struct dht_certificate dht_certificate;
    OPENDHT_C_PUBLIC dht_certificate* dht_certificate_import(const uint8_t* dat, size_t dat_size);
    OPENDHT_C_PUBLIC dht_infohash dht_certificate_get_id(const dht_certificate*);
    OPENDHT_C_PUBLIC dht_pkid dht_certificate_get_long_id(const dht_certificate*);
    OPENDHT_C_PUBLIC dht_publickey* dht_certificate_get_publickey(const dht_certificate*);
    OPENDHT_C_PUBLIC void dht_certificate_delete(dht_certificate*);
    
    struct OPENDHT_PUBLIC dht_identity {
        dht_privatekey* privatekey;
        dht_certificate* certificate;
    };
    typedef struct dht_identity dht_identity;
    OPENDHT_C_PUBLIC dht_identity dht_identity_generate(const char* common_name, const dht_identity* ca);
    OPENDHT_C_PUBLIC void dht_identity_delete(dht_identity*);
    
    // dht::Value
    struct OPENDHT_C_PUBLIC dht_value;
    typedef struct dht_value dht_value;
    typedef uint64_t dht_value_id;
    OPENDHT_C_PUBLIC dht_value* dht_value_new(const uint8_t* data, size_t size);
    OPENDHT_C_PUBLIC dht_value* dht_value_new_from_string(const char* str);
    OPENDHT_C_PUBLIC dht_value* dht_value_ref(const dht_value*);
    OPENDHT_C_PUBLIC void dht_value_unref(dht_value*);
    OPENDHT_C_PUBLIC dht_data_view dht_value_get_data(const dht_value* data);
    OPENDHT_C_PUBLIC dht_value_id dht_value_get_id(const dht_value* data);
    OPENDHT_C_PUBLIC dht_publickey* dht_value_get_owner(const dht_value* data);
    OPENDHT_C_PUBLIC dht_infohash dht_value_get_recipient(const dht_value* data);
    OPENDHT_C_PUBLIC const char* dht_value_get_user_type(const dht_value* data);
    OPENDHT_C_PUBLIC void dht_value_set_user_type(dht_value* data, const char* user_type);
    
    // callbacks
    typedef bool (*dht_get_cb)(const dht_value* value, void* user_data);
    typedef bool (*dht_value_cb)(const dht_value* value, bool expired, void* user_data);
    typedef void (*dht_done_cb)(bool ok, void* user_data);
    typedef void (*dht_shutdown_cb)(void* user_data);
    
    struct OPENDHT_C_PUBLIC dht_op_token;
    typedef struct dht_op_token dht_op_token;
    OPENDHT_C_PUBLIC void dht_op_token_delete(dht_op_token* token);
    
    // config
    struct OPENDHT_PUBLIC dht_node_config {
        dht_infohash node_id;
        uint32_t network;
        bool is_bootstrap;
        bool maintain_storage;
        const char* persist_path;
    };
    typedef struct dht_node_config dht_node_config;
    
    struct OPENDHT_PUBLIC dht_secure_config {
        dht_node_config node_config;
        dht_identity id;
    };
    typedef struct dht_secure_config dht_secure_config;
    
    struct OPENDHT_PUBLIC dht_runner_config {
        dht_secure_config dht_config;
        bool threaded;
        const char* proxy_server;
        const char* push_node_id;
        const char* push_token;
        bool peer_discovery;
        bool peer_publish;
        dht_certificate* server_ca;
        dht_identity client_identity;
    };
    typedef struct dht_runner_config dht_runner_config;
    OPENDHT_C_PUBLIC void dht_runner_config_default(dht_runner_config* config);
    
    // dht::DhtRunner
    struct OPENDHT_C_PUBLIC dht_runner;
    typedef struct dht_runner dht_runner;
    OPENDHT_C_PUBLIC dht_runner* dht_runner_new(void);
    OPENDHT_C_PUBLIC void dht_runner_delete(dht_runner* runner);
    /* Returns 0 on success, standard error code on failure */
    OPENDHT_C_PUBLIC int dht_runner_run(dht_runner* runner, in_port_t port);
    /* Returns 0 on success, standard error code on failure */
    OPENDHT_C_PUBLIC int dht_runner_run_config(dht_runner* runner, in_port_t port, const dht_runner_config* config);
    OPENDHT_C_PUBLIC void dht_runner_ping(dht_runner* runner, struct sockaddr* addr, socklen_t addr_len, dht_done_cb done_cb, void* cb_user_data);
    OPENDHT_C_PUBLIC void dht_runner_bootstrap(dht_runner* runner, const char* host, const char* service);
    OPENDHT_C_PUBLIC void dht_runner_get(dht_runner* runner, const dht_infohash* hash, dht_get_cb cb, dht_done_cb done_cb, void* cb_user_data);
    OPENDHT_C_PUBLIC dht_op_token* dht_runner_listen(dht_runner* runner, const dht_infohash* hash, dht_value_cb cb, dht_shutdown_cb done_cb, void* cb_user_data);
    OPENDHT_C_PUBLIC void dht_runner_cancel_listen(dht_runner* runner, const dht_infohash* hash, dht_op_token* token);
    OPENDHT_C_PUBLIC void dht_runner_put(dht_runner* runner, const dht_infohash* hash, const dht_value* value, dht_done_cb done_cb, void* cb_user_data, bool permanent);
    OPENDHT_C_PUBLIC void dht_runner_put_signed(dht_runner* runner, const dht_infohash* hash, const dht_value* value, dht_done_cb done_cb, void* cb_user_data, bool permanent);
    OPENDHT_C_PUBLIC void dht_runner_put_encrypted(dht_runner* runner, const dht_infohash* hash, const dht_infohash* to, const dht_value* value, dht_done_cb done_cb, void* cb_user_data, bool permanent);
    OPENDHT_C_PUBLIC void dht_runner_cancel_put(dht_runner* runner, const dht_infohash* hash, dht_value_id value_id);
    OPENDHT_C_PUBLIC void dht_runner_shutdown(dht_runner* runner, dht_shutdown_cb done_cb, void* cb_user_data);
    OPENDHT_C_PUBLIC dht_infohash dht_runner_get_node_id(const dht_runner* runner);
    OPENDHT_C_PUBLIC dht_infohash dht_runner_get_id(const dht_runner* runner);
    OPENDHT_C_PUBLIC bool dht_runner_is_running(const dht_runner* runner);
    OPENDHT_C_PUBLIC in_port_t dht_runner_get_bound_port(const dht_runner* runner, sa_family_t af);
    /** Returns null-terminated array that must be freed after use as well as each element */
    OPENDHT_C_PUBLIC struct sockaddr** dht_runner_get_public_address(const dht_runner* runner);
    
    #ifdef __cplusplus
    }
    #endif