fsm.js 3.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687
  1. "use strict";
  2. var __read = (this && this.__read) || function (o, n) {
  3. var m = typeof Symbol === "function" && o[Symbol.iterator];
  4. if (!m) return o;
  5. var i = m.call(o), r, ar = [], e;
  6. try {
  7. while ((n === void 0 || n-- > 0) && !(r = i.next()).done) ar.push(r.value);
  8. }
  9. catch (error) { e = { error: error }; }
  10. finally {
  11. try {
  12. if (r && !r.done && (m = i["return"])) m.call(i);
  13. }
  14. finally { if (e) throw e.error; }
  15. }
  16. return ar;
  17. };
  18. Object.defineProperty(exports, "__esModule", { value: true });
  19. exports.useService = exports.useMachine = void 0;
  20. var fsm_1 = require("@xstate/fsm");
  21. var react_1 = require("react");
  22. var use_isomorphic_layout_effect_1 = require("use-isomorphic-layout-effect");
  23. var with_selector_1 = require("use-sync-external-store/shim/with-selector");
  24. var useConstant_1 = require("./useConstant");
  25. function identity(a) {
  26. return a;
  27. }
  28. var getServiceState = function (service) {
  29. var currentValue;
  30. service
  31. .subscribe(function (state) {
  32. currentValue = state;
  33. })
  34. .unsubscribe();
  35. return currentValue;
  36. };
  37. function useMachine(stateMachine, options) {
  38. var persistedStateRef = (0, react_1.useRef)();
  39. if (process.env.NODE_ENV !== 'production') {
  40. var _a = __read((0, react_1.useState)(stateMachine), 1), initialMachine = _a[0];
  41. if (stateMachine !== initialMachine) {
  42. console.warn('Machine given to `useMachine` has changed between renders. This is not supported and might lead to unexpected results.\n' +
  43. 'Please make sure that you pass the same Machine as argument each time.');
  44. }
  45. }
  46. var _b = __read((0, useConstant_1.default)(function () {
  47. var queue = [];
  48. var service = (0, fsm_1.interpret)((0, fsm_1.createMachine)(stateMachine.config, options ? options : stateMachine._options));
  49. var send = service.send;
  50. service.send = function (event) {
  51. if (service.status === fsm_1.InterpreterStatus.NotStarted) {
  52. queue.push(event);
  53. return;
  54. }
  55. send(event);
  56. persistedStateRef.current = service.state;
  57. };
  58. return [service, queue];
  59. }), 2), service = _b[0], queue = _b[1];
  60. (0, use_isomorphic_layout_effect_1.default)(function () {
  61. if (options) {
  62. service._machine._options = options;
  63. }
  64. });
  65. var useServiceResult = useService(service);
  66. (0, react_1.useEffect)(function () {
  67. service.start(persistedStateRef.current);
  68. queue.forEach(service.send);
  69. persistedStateRef.current = service.state;
  70. return function () {
  71. service.stop();
  72. };
  73. }, []);
  74. return useServiceResult;
  75. }
  76. exports.useMachine = useMachine;
  77. var isEqual = function (_prevState, nextState) { return nextState.changed === false; };
  78. function useService(service) {
  79. var getSnapshot = (0, react_1.useCallback)(function () { return getServiceState(service); }, [service]);
  80. var subscribe = (0, react_1.useCallback)(function (handleStoreChange) {
  81. var unsubscribe = service.subscribe(handleStoreChange).unsubscribe;
  82. return unsubscribe;
  83. }, [service]);
  84. var storeSnapshot = (0, with_selector_1.useSyncExternalStoreWithSelector)(subscribe, getSnapshot, getSnapshot, identity, isEqual);
  85. return [storeSnapshot, service.send, service];
  86. }
  87. exports.useService = useService;