Hippy/framework/voltron/lib/engine/bundle.dart

//
// Tencent is pleased to support the open source community by making
// Hippy available.
//
// Copyright (C) 2022 THL A29 Limited, a Tencent company.
// All rights reserved.
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
//

import 'dart:async';

import 'package:dio/dio.dart';
import 'package:path_provider/path_provider.dart';
import 'package:voltron_renderer/voltron_renderer.dart';

import '../bridge.dart';

abstract class VoltronBundleLoader {
  Future<bool> load(VoltronBridgeManager bridge, Callback callback);

  String? get path;

  String? get rawPath;

  String? get bundleUniKey;

  bool get canUseCodeCache;

  String get codeCacheTag;
}

class AssetBundleLoader implements VoltronBundleLoader {
  static const String kAssetsStr = "assets://";

  final String _assetPath;

  final bool _canUseCodeCache;

  final String _codeCacheTag;

  String get assetPath => _assetPath;

  const AssetBundleLoader(String assetPath,
      {bool canUseCodeCache = false, String codeCacheTag = ''})
      : _assetPath = assetPath,
        _canUseCodeCache = canUseCodeCache,
        _codeCacheTag = codeCacheTag;

  @override
  Future<bool> load(VoltronBridgeManager bridge, Callback callback) async {
    if (isEmpty(_assetPath)) {
      return false;
    }

    var result = false;
    var watch = Stopwatch();
    watch.start();
    String uri = _assetPath;
    if (!_assetPath.startsWith('assets://')) {
      if (_assetPath.startsWith("/")) {
        uri = 'assets:/$_assetPath';
      } else {
        uri = 'assets://$_assetPath';
      }
    }
    try {
      result = await bridge.runScriptFromUri(uri, canUseCodeCache, codeCacheTag, (value) {
        watch.stop();
        LogUtils.profile("runScriptFromAssets", watch.elapsedMilliseconds);
        callback(value, null);
      });
    } catch (e) {
      callback(-1, StateError(e.toString()));
    }

    return result;
  }

  @override
  String get bundleUniKey => path;

  @override
  bool get canUseCodeCache => _canUseCodeCache;

  @override
  String get codeCacheTag => _codeCacheTag;

  @override
  String get path {
    if (!_assetPath.startsWith(kAssetsStr)) {
      return kAssetsStr + _assetPath;
    } else {
      return _assetPath;
    }
  }

  @override
  String get rawPath => _assetPath;
}

class FileBundleLoader implements VoltronBundleLoader {
  static const String kFileStr = "file://";

  final String? _filePath;

  final bool _canUseCodeCache;

  final String _codeCacheTag;

  FileBundleLoader(String? filePath, {bool canUseCodeCache = false, String codeCacheTag = ''})
      : _filePath = filePath,
        _canUseCodeCache = canUseCodeCache,
        _codeCacheTag = codeCacheTag;

  @override
  String? get bundleUniKey => path;

  @override
  bool get canUseCodeCache => _canUseCodeCache;

  @override
  String get codeCacheTag => _codeCacheTag;

  @override
  String? get path {
    var filePath = _filePath;
    if (filePath != null && !filePath.startsWith(kFileStr)) {
      return kFileStr + filePath;
    } else {
      return filePath;
    }
  }

  @override
  String? get rawPath => _filePath;

  @override
  Future<bool> load(VoltronBridgeManager bridge, Callback callback) async {
    var curFilePath = _filePath??'';
    if (isEmpty(curFilePath)) {
      return false;
    }
    var result = false;
    var watch = Stopwatch();
    watch.start();
    String uri = (!curFilePath.startsWith('file://'))
        ? ('file://$curFilePath')
        : curFilePath;
    try {
      result = await bridge
          .runScriptFromUri(uri, _canUseCodeCache, _codeCacheTag, (value) {
        watch.stop();
        LogUtils.profile("runScriptFromFile", watch.elapsedMilliseconds);
        callback(value, null);
      });
    } catch (e) {
      callback(-1, StateError(e.toString()));
    }

    return result;
  }
}

class HttpBundleLoader implements VoltronBundleLoader {
  static const String kFileStr = "file://";

  String? _filePath;

  final String? _url;

  final bool _canUseCodeCache;

  final String _codeCacheTag;

  HttpBundleLoader(
    String? url, {
    bool canUseCodeCache = false,
    String codeCacheTag = '',
  })  : _url = url,
        _canUseCodeCache = canUseCodeCache,
        _codeCacheTag = codeCacheTag;

  @override
  String? get bundleUniKey => _url;

  @override
  bool get canUseCodeCache => _canUseCodeCache;

  @override
  String get codeCacheTag => _codeCacheTag;

  @override
  String? get path {
    var filePath = _filePath;
    if (filePath != null && !filePath.startsWith(kFileStr)) {
      return kFileStr + filePath;
    } else {
      return filePath;
    }
  }

  @override
  String? get rawPath => _url;

  void setIsDebugMode(bool isDebugMode) {}

  @override
  Future<bool> load(VoltronBridgeManager bridge, Callback callback) async {
    var reg = RegExp(r"^https?:\/\/");
    var curUrl = _url ?? '';
    if (isEmpty(curUrl) || !reg.hasMatch(curUrl)) {
      return false;
    }
    var result = false;
    var watch = Stopwatch();
    watch.start();
    try {
      result = await bridge.runScriptFromUri(
        curUrl,
        _canUseCodeCache,
        _codeCacheTag,
        (value) {
          watch.stop();
          LogUtils.profile("runScriptFromFile", watch.elapsedMilliseconds);
          callback(value, null);
        },
      );
    } catch (e) {
      callback(-1, StateError(e.toString()));
    }

    return result;
  }
}

Future<String> downloadFile(String url) async {
  var tmp = await getTemporaryDirectory();
  LogUtils.i("downloadFile", url);
  var saveFilePath = '${tmp.path}jsbundle/index.bundle.js';
  await Dio().download(url, saveFilePath);
  return saveFilePath;
}