librqbit 8.1.1

The main library used by rqbit torrent client. The binary is just a small wrapper on top of it.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79

import { useContext, useEffect, useState } from "react";
import {
  TorrentDetails,
  TorrentId,
  TorrentStats,
  STATE_INITIALIZING,
  STATE_LIVE,
} from "../api-types";
import { APIContext, RefreshTorrentStatsContext } from "../context";
import { customSetInterval } from "../helper/customSetInterval";
import { loopUntilSuccess } from "../helper/loopUntilSuccess";
import { TorrentRow } from "./TorrentRow";

export const Torrent: React.FC<{
  id: number;
  torrent: TorrentId;
}> = ({ id, torrent }) => {
  const [detailsResponse, updateDetailsResponse] =
    useState<TorrentDetails | null>(null);
  const [statsResponse, updateStatsResponse] = useState<TorrentStats | null>(
    null,
  );
  const [forceStatsRefresh, setForceStatsRefresh] = useState(0);
  const API = useContext(APIContext);

  const forceStatsRefreshCallback = () => {
    setForceStatsRefresh(forceStatsRefresh + 1);
  };

  // Update details once then when asked for.
  useEffect(() => {
    return loopUntilSuccess(async () => {
      await API.getTorrentDetails(torrent.id).then(updateDetailsResponse);
    }, 1000);
  }, [forceStatsRefresh]);

  // Update stats once then forever.
  useEffect(
    () =>
      customSetInterval(async () => {
        const errorInterval = 10000;
        const liveInterval = 1000;
        const nonLiveInterval = 10000;

        return API.getTorrentStats(torrent.id)
          .then((stats) => {
            updateStatsResponse(stats);
            return stats;
          })
          .then(
            (stats) => {
              if (
                stats.state == STATE_INITIALIZING ||
                stats.state == STATE_LIVE
              ) {
                return liveInterval;
              }
              return nonLiveInterval;
            },
            () => {
              return errorInterval;
            },
          );
      }, 0),
    [forceStatsRefresh],
  );

  return (
    <RefreshTorrentStatsContext.Provider
      value={{ refresh: forceStatsRefreshCallback }}
    >
      <TorrentRow
        id={id}
        detailsResponse={detailsResponse}
        statsResponse={statsResponse}
      />
    </RefreshTorrentStatsContext.Provider>
  );
};