@@ -1,244 +0,0 @@
1−import { useState, useCallback, useMemo } from 'react';
2−import { Nothing } from 'folktale/maybe';
3−import * as ob from 'urbit-ob';
4−
5−import { getVaneName, getVaneNumber } from 'lib/hosting';
6−import SolarisClient from 'lib/SolarisClient';
7−
8−import { usePointCursor } from 'store/pointCursor';
9−
10−const STATE = {
11− UNKNOWN: 'UNKNOWN',
12− MISSING: 'MISSING',
13− RUNNING: 'RUNNING',
14− PENDING: 'PENDING',
15−};
16−
17−function useHostingStore(url, domain, disabled) {
18− const client = new SolarisClient(url);
19−
20− const { pointCursor } = usePointCursor();
21−
22− const [bootProgress, setBootProgress] = useState(0);
23− const [bootMessage, setBootMessage] = useState('Assembling Urbit');
24− const [startTime] = useState(Date.now());
25−
26− const [status, _setStatus] = useState(STATE.UNKNOWN);
27− const setStatus = useCallback(
28− s => {
29− _setStatus(s);
30− },
31− [_setStatus]
32− );
33−
34− const [sysEvents, setSysEvents] = useState([]);
35− const [newEvents, setNewEvents] = useState([]);
36− const [runEvents, setRunEvents] = useState([]);
37−
38− const [error, _setError] = useState();
39− const setError = useCallback(
40− error => {
41− _setError(error);
42− if (error) {
43− setStatus(STATE.UNKNOWN);
44− console.error(error);
45− }
46− },
47− [_setError, setStatus]
48− );
49−
50− const unknown = status === STATE.UNKNOWN;
51− const missing = status === STATE.MISSING;
52− const running = status === STATE.RUNNING;
53− const pending = status === STATE.PENDING;
54−
55− let syncStatus;
56−
57− const resetEvents = useCallback(() => {
58− setSysEvents([]);
59− setNewEvents([]);
60− setRunEvents([]);
61− }, [setSysEvents, setNewEvents, setRunEvents]);
62−
63− const newSource = useCallback(
64− (url, retry = 0) => {
65− let source = new EventSource(url);
66−
67− source.addEventListener('sys', event => {
68− const sysEvent = JSON.parse(event.data);
69− const time = new Date(sysEvent.object.firstTimestamp).getTime();
70− if (time > startTime) {
71− setSysEvents(previous => [...previous, sysEvent]);
72− }
73− });
74−
75− source.addEventListener('new', event => {
76− if (event.data !== '') {
77− setNewEvents(previous => [...previous, event.data]);
78− }
79− if (event.data === '1-b') {
80− setBootMessage('Compiling Hoon');
81− setBootProgress(0.2);
82− } else if (event.data === '1-c') {
83− setBootProgress(0.25);
84− } else if (event.data === '%arvo-assembly') {
85− setBootMessage('Compiling Urbit OS');
86− setBootProgress(0.3);
87− } else if (event.data.startsWith('[%vane %')) {
88− const vane = getVaneName(event.data.slice(8, 9));
89− setBootMessage(`Compiling vane: ${vane}`);
90− setBootProgress(0.3 + 0.05 * getVaneNumber(event.data.slice(8, 9)));
91− } else if (event.data === 'pier: boot complete') {
92− setBootMessage('Ship starting');
93− setBootProgress(0.85);
94− }
95− });
96−
97− source.addEventListener('run', event => {
98− if (event.data === 'goad: recompiling all apps') {
99− setBootProgress(1.0);
100− setBootMessage('Ship Launched');
101− syncStatus();
102− }
103− if (event.data !== '') {
104− setRunEvents(previous => [...previous, event.data]);
105− }
106− });
107−
108− source.addEventListener(
109− 'error',
110− error => {
111− if (source.readyState === EventSource.CLOSED) {
112− if (retry < 5) {
113− newSource(url, retry + 1);
114− return;
115− }
116− setError(error);
117− }
118− },
119− false
120− );
121− },
122− [setError, startTime, syncStatus]
123− );
124−
125− const getEvents = useCallback(() => {
126− try {
127− if (Nothing.hasInstance(pointCursor) || disabled) {
128− return;
129− }
130− const patp = ob.patp(pointCursor.value);
131− setError(undefined);
132−
133− resetEvents();
134−
135− const url = client.getShipsByPatpUrl(patp) + '/events';
136− newSource(url);
137− } catch (error) {
138− setError(error);
139− }
140− }, [setError, disabled, resetEvents, client, pointCursor, newSource]);
141−
142− syncStatus = useCallback(async () => {
143− try {
144− if (Nothing.hasInstance(pointCursor) || disabled) {
145− return;
146− }
147− const patp = ob.patp(pointCursor.value);
148− setError(undefined);
149−
150− resetEvents();
151−
152− const response = await client.getShipsByPatp(patp);
153−
154− if (response.status === 404) {
155− setStatus(STATE.MISSING);
156− } else if (!response.ok) {
157− setError(response.statusText);
158− } else {
159− const ship = await response.json();
160−
161− if (ship.status === 'Pending') {
162− setStatus(STATE.PENDING);
163− getEvents();
164− } else if (ship.status === 'Running') {
165− setStatus(STATE.RUNNING);
166− } else {
167− setError(ship);
168− }
169− }
170− } catch (error) {
171− setError(error);
172− }
173− }, [
174− client,
175− getEvents,
176− pointCursor,
177− resetEvents,
178− setError,
179− setStatus,
180− disabled,
181− ]);
182−
183− const hostedShipUrl = useMemo(
184− () => `http://${ob.patp(pointCursor.getOrElse('')).slice(1)}.${domain}`,
185− [pointCursor, domain]
186− );
187−
188− const create = useCallback(
189− async keyfile => {
190− try {
191− if (Nothing.hasInstance(pointCursor) || disabled) {
192− return;
193− }
194− const patp = ob.patp(pointCursor.value).slice(1);
195− setError(undefined);
196−
197− setStatus(STATE.PENDING);
198− setBootProgress(0.1);
199−
200− const response = await client.postShips({
201− patp,
202− key: keyfile,
203− debug: true,
204− fake: false,
205− });
206−
207− if (!response.ok) {
208− setError(response.statusText);
209− } else {
210− getEvents();
211− }
212− } catch (error) {
213− setError(error);
214− }
215− },
216− [pointCursor, setError, setStatus, client, getEvents, disabled]
217− );
218−
219− return {
220− error,
221− unknown,
222− missing,
223− running,
224− pending,
225− url: hostedShipUrl,
226−
227− sysEvents,
228− newEvents,
229− runEvents,
230−
231− syncStatus,
232− getEvents,
233− create,
234−
235− bootProgress,
236− bootMessage,
237−
238− disabled,
239− // debugging
240− status,
241− };
242−}
243−
244−export default useHostingStore;