duit_kernel/lib/src/action_api/event_resolver.dart at e4ae9cf21db5c177c5321ed790c3db3cff330a28 · Duit-Foundation/duit_kernel · GitHub

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
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
import 'dart:async';

import 'package:duit_kernel/duit_kernel.dart';
import 'package:flutter/material.dart' show BuildContext;

abstract class EventResolver {
  final UIDriver driver;
  final DebugLogger? logger;

  EventResolver({
    required this.driver,
    this.logger,
  });

  Future<void> resolveEvent(BuildContext context, dynamic eventData);
}

final class DefaultEventResolver extends EventResolver {
  DefaultEventResolver({
    required super.driver,
    super.logger,
  });

  @override
  Future<void> resolveEvent(BuildContext context, dynamic eventData) async {
    ServerEvent event;

    if (eventData is ServerEvent) {
      event = eventData;
    } else {
      event = ServerEvent.parseEvent(eventData);
    }

    try {
      final driver = this.driver;

      switch (event) {
        case UpdateEvent():
          event.updates.forEach((key, value) async {
            await driver.updateAttributes(key, value);
          });
          break;
        case NavigationEvent():
          assert(driver.externalEventHandler != null,
              "ExternalEventHandler instance is not set");
          await driver.externalEventHandler?.handleNavigation(
            context,
            event.path,
            event.extra,
          );
          break;
        case OpenUrlEvent():
          assert(driver.externalEventHandler != null,
              "ExternalEventHandler instance is not set");
          await driver.externalEventHandler?.handleOpenUrl(event.url);
          break;
        case CustomEvent():
          if (driver.isModule) {
            await driver.driverChannel
                ?.invokeMethod<Map<String, dynamic>>(event.key, event.extra);
          } else {
            await driver.externalEventHandler?.handleCustomEvent(
              context,
              event.key,
              event.extra,
            );
          }
          break;
        case SequencedEventGroup():
          for (final entry in event.events) {
            if (context.mounted) {
              await resolveEvent(context, entry.event);
              await Future.delayed(entry.delay);
            }
          }
          break;
        case CommonEventGroup():
          for (final entry in event.events) {
            await resolveEvent(context, entry.event);
          }
          break;
        case CommandEvent():
          final c = driver.getController(event.command.controllerId);
          await c?.emitCommand(event.command);
          break;
        case TimerEvent():
          final evt = event;
          Timer(
            evt.timerDelay,
            () async {
              await resolveEvent(context, evt.payload);
            },
          );
          break;
        default:
          break;
      }
    } catch (e, s) {
      logger?.error(
        "Error while resolving ${event.type} event",
        error: e,
        stackTrace: s,
      );
    }
  }
}