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