import act.app.App; //导入依赖的package包/类
@Override
protected IStorageService initStorageService(String id, App app, Map<String, String> conf) {
    conf = calibrate(conf, "storage.fs.");
    FileSystemService ss = new FileSystemService(conf);
    ss.setKeyNameProvider(UploadFileStorageService.ACT_STORAGE_KEY_NAME_PROVIDER);
    String home = conf.get(CONF_HOME_DIR);
    String url = ss.getStaticWebEndpoint();
    if (null != url) {
        if (!url.endsWith("/")) {
            url = url + "/";
        }
        if (S.notBlank(url) && !url.startsWith("http") && !url.startsWith("//")) {
            App.instance().router().addMapping(H.Method.GET, url, new FileGetter(new File(home)), RouteSource.BUILD_IN);
        }
    }
    return ss;
}
 

import act.app.App; //导入依赖的package包/类
private AAAService initializeAAAService(final App app, final ActAAAService appSvc) {
    AAAService svc = services.get(app);
    if (null != svc) {
        return svc;
    }
    svc = null == appSvc ? new AAAService(app) : new AAAService(app, appSvc);
    services.put(app, svc);
    EventBus eventBus = app.eventBus();
    eventBus.bind(AppEventId.STOP, new AppEventListenerBase<AppStop>("aaa-stop") {
        @Override
        public void on(AppStop event) {
            services.remove(app);
        }
    });
    return svc;
}
 

import act.app.App; //导入依赖的package包/类
protected void setup() throws Exception {
    mockApp = mock(App.class);
    Field f = App.class.getDeclaredField("INST");
    f.setAccessible(true);
    f.set(null, mockApp);
    mockJobManager = mock(AppJobManager.class);
    mockEventBus = mock(EventBus.class);
    when(mockApp.jobManager()).thenReturn(mockJobManager);
    when(mockApp.eventBus()).thenReturn(mockEventBus);
    mockAppConfig = mock(AppConfig.class);
    when(mockAppConfig.possibleControllerClass(argThat(new StartsWith("testapp.controller.")))).thenReturn(true);
    mockActionContext = mock(ActionContext.class);
    when(mockActionContext.app()).thenReturn(mockApp);
    when(mockActionContext.config()).thenReturn(mockAppConfig);
    mockRouter = mock(Router.class);
    when(mockApp.config()).thenReturn(mockAppConfig);
    when(mockApp.router()).thenReturn(mockRouter);
    when(mockApp.getInstance(any(Class.class))).thenAnswer(new Answer<Object>() {
        @Override
        public Object answer(InvocationOnMock invocation) throws Throwable {
            Object[] args = invocation.getArguments();
            return $.newInstance((Class)args[0]);
        }
    });
    mockReq = mock(H.Request.class);
    mockResp = mock(H.Response.class);
}
 

import act.app.App; //导入依赖的package包/类
@BeforeClass
public static void prepare() {
    try {
        Field f = Act.class.getDeclaredField("pluginManager");
        f.setAccessible(true);
        f.set(null, new GenericPluginManager());
    } catch (Exception e) {
        throw E.unexpected(e);
    }
    app = App.testInstance();
    config = app.config();
    RequestHandlerResolver controllerLookup = new MockRequestHandlerResolver();
    router = new Router(controllerLookup, app);
    InputStream is = TestBase.class.getResourceAsStream("/routes");
    String fc = IO.readContentAsString(is);
    builder = new RouteTableRouterBuilder(fc.split("[\r\n]+"));
    builder.build(router);
    Play.pluginCollection = new PluginCollection();
    URL url = TestBase.class.getResource("/routes");
    Play.applicationPath = new File(FastStr.of(url.getPath()).beforeLast('/').toString());
    Play.routes = VirtualFile.fromRelativePath("routes");
    play.mvc.Router.load("");
}
 

import act.app.App; //导入依赖的package包/类
@Override
public void start() {
    bootUp();
    for (int port : registry.keySet()) {
        NetworkHandler client = registry.get(port);
        if (!trySetUpClient(client, port, securePorts.contains(port))) {
            failed.put(port, client);
        } else {
            Act.LOGGER.info("network client hooked on port: %s", port);
        }
    }
    started = true;
    App app = Act.app();
    if (null != app) {
        app.registerHotReloadListener(new App.HotReloadListener() {
            @Override
            public void preHotReload() {
                simpleWebSocketConnector = null;
            }
        });
    }
}
 

import act.app.App; //导入依赖的package包/类
AutoConfigLoader(App app, Class<?> autoConfigClass) {
    this.conf = app.config();
    this.autoConfigClass = autoConfigClass;
    this.ns = (autoConfigClass.getAnnotation(AutoConfig.class)).value();
    this.resolverManager = app.resolverManager();
    this.injector = app.injector();
    synchronized (AutoConfigLoader.class) {
        allowChangeFinalField();
        app.jobManager().on(SysEventId.START, new Runnable() {
            @Override
            public void run() {
                resetFinalFieldUpdate();
            }
        });
    }
}
 

import act.app.App; //导入依赖的package包/类
public HeaderValueLoader(String name, BeanSpec beanSpec) {
    this.key = key(name, beanSpec);
    this.targetType = beanSpec.rawType();
    this.isArray = targetType.isArray();
    this.multiValues = (isArray || Collection.class.isAssignableFrom(targetType));
    if (this.isArray) {
        this.elementType = this.targetType.getComponentType();
    } else if (this.multiValues) {
        this.elementType = (Class)(beanSpec.typeParams().get(0));
    } else {
        this.elementType = null;
    }
    Class effectiveType = null != elementType ? elementType : targetType;
    this.stringValueResolver = App.instance().resolverManager().resolver(effectiveType, beanSpec);
    E.illegalArgumentIf(null == this.stringValueResolver, "Cannot find out StringValueResolver for %s", beanSpec);
    this.defVal = StringValueResolverValueLoaderBase.defVal(null, effectiveType);
}
 

import act.app.App; //导入依赖的package包/类
@Override
public _SequenceNumberGenerator get() {
    if (generators.size() > 1) {
        App app = Act.app();
        AppConfig config = app.config();
        DbServiceManager dbServiceManager = app.dbServiceManager();
        for (_SequenceNumberGenerator gen: generators) {
            if (!_SequenceNumberGenerator.InMemorySequenceNumberGenerator.class.isInstance(gen)) {
                try {
                    gen.configure(config, dbServiceManager);
                } catch (Exception e) {
                    continue;
                }
                return gen;
            }
        }
    }
    return generators.get(0);
}
 

import act.app.App; //导入依赖的package包/类
/**
 * If the `invokerClass` specified is singleton, or without field or all fields are
 * stateless, then return an instance of the invoker class. Otherwise, return null
 * @param invokerClass the invoker class
 * @param app the app
 * @return an instance of the invokerClass or `null` if invoker class is stateful class
 */
public static Object tryGetSingleton(Class<?> invokerClass, App app) {
    Object singleton = app.singleton(invokerClass);
    if (null == singleton) {
        // check if there are fields
        List<Field> fields = $.fieldsOf(invokerClass);
        if (fields.isEmpty()) {
            singleton = app.getInstance(invokerClass);
        }
        boolean stateful = false;
        for (Field field : fields) {
            if (!isGlobalOrStateless(field)) {
                stateful = true;
                break;
            }
        }
        if (!stateful) {
            singleton = app.getInstance(invokerClass);
        }
    }
    return singleton;
}
 

import act.app.App; //导入依赖的package包/类
private EventBus(App app, boolean once) {
    super(app, true);
    sysEventLookup = initSysEventLookup(app);

    sysEventListeners = initAppListenerArray();
    asyncSysEventListeners = initAppListenerArray();

    actEventListeners = new ConcurrentHashMap<>();
    asyncActEventListeners = new ConcurrentHashMap<>();

    adhocEventListeners = new ConcurrentHashMap<>();
    asyncAdhocEventListeners = new ConcurrentHashMap<>();

    loadDefaultEventListeners();
    if (!once) {
        onceBus = new EventBus(app, true);
        onceBus.once = true;
    }
}
 

import act.app.App; //导入依赖的package包/类
@Override
public void invoke(Object... args) {
    int paramNo = paramTypes.size();
    int argsNo = args.length;
    Object[] realArgs = args;
    if (paramNo != argsNo || providedParamSize > 0) {
        realArgs = new Object[paramNo + providedParamSize];
        System.arraycopy(args, 0, realArgs, 0, Math.min(paramNo, argsNo));
        App app = Act.app();
        for (int i = 0; i < providedParamSize; ++i) {
            realArgs[i + paramNo] = app.getInstance(providedParamTypes.get(i));
        }
    }
    Object host = host();
    if (null == host) {
        $.invokeStatic(method, realArgs);
    } else {
        $.invokeVirtual(host, method, realArgs);
    }
}
 

import act.app.App; //导入依赖的package包/类
@Override
public void hookLifecycleInterceptors() {
    App.instance().eventBus().bind(PreEbeanCreation.class, new ActEventListenerBase<PreEbeanCreation>("storage:hook-ebean-lifecycle-interceptor") {
        @Override
        public void on(PreEbeanCreation event) throws Exception {
            ServerConfig config = event.source();
            BeanPostLoad postLoad = new StorageFieldConverter(ssm());
            config.add(postLoad);
            BeanPersistController persistController = (BeanPersistController) postLoad;
            config.add(persistController);
        }
    });
}
 

import act.app.App; //导入依赖的package包/类
private StorageServiceManager ssm() {
    if (null == ssm) {
        synchronized (this) {
            if (null == ssm) {
                ssm = App.instance().singleton(StorageServiceManager.class);
            }
        }
    }
    return ssm;
}
 

import act.app.App; //导入依赖的package包/类
@Override
public void onInjection(Object injectee, BeanSpec spec) {
    final EbeanDao dao = $.cast(injectee);
    if (dao.ebeanServerProvided()) {
        return;
    }
    List<Type> typeParameters = spec.typeParams();
    if (typeParameters.isEmpty()) {
        typeParameters = Generics.typeParamImplementations(spec.rawType(), EbeanDao.class);
    }
    if (null == typeParameters) {
        logger.warn("No type parameter information provided");
        return;
    }
    final $.T2<Class, String> resolved = resolve(typeParameters);
    DbService dbService = App.instance().dbServiceManager().dbService(resolved._2);
    if (dbService instanceof EbeanService) {
        final EbeanService service = $.cast(dbService);
        Act.eventBus().bind(AppEventId.DB_SVC_LOADED, new AppEventListenerBase() {
            @Override
            public void on(EventObject eventObject) throws Exception {
                dao.ebean(service.ebean());
                dao.modelType(resolved._1);
            }
        });
    }
}
 

import act.app.App; //导入依赖的package包/类
private void generateTestData(App app) {
    testData = new ArrayList<Employee>();
    Employee.Grade[] grades = Employee.Grade.values();
    for (String name : names) {
        testData.add(generateEmployee(app.cuid(), name, $.random(grades)));
    }
}
 

import act.app.App; //导入依赖的package包/类
AAAService(final App app) {
    super(app);
    loadAuthenticateList();
    sessionKeyUsername = app.config().sessionKeyUsername();
    authorizationService = new SimpleAuthorizationService();
    auditor = DumbAuditor.INSTANCE;
    allowBasicAuthentication = app.config().basicAuthenticationEnabled();
    postOperations(app);
}
 

import act.app.App; //导入依赖的package包/类
public void buildService(App app, ActAAAService service) {
    AAAService aaa = initializeAAAService(app, service);
    // we need to check if persistent service is already
    // provisioned with buildService(App, AAAPersistentService) call
    if (null == aaa.persistentService()) {
        aaa.persistentService(new DefaultPersistentService(service));
        aaa.persistentService();
    }
    // we need to check if authentication service is already
    // provisioned with buildService(App, AuthenticationService) call
    if (null == aaa.authenticationService()) {
        aaa.authenticationService(service);
    }
}
 

import act.app.App; //导入依赖的package包/类
@Override
protected void applyTo(App app) {
    loadPluginAutoConfig(AAAConfig.class, app);
    loadPluginAutoConfig(AAAService.class, app);
    ensureDDL();
    ensureLoginUrl(app);
}
 

import act.app.App; //导入依赖的package包/类
private void ensureLoginUrl(final App app) {
    app.jobManager().beforeAppStart(new Runnable() {
        @Override
        public void run() {
            if (S.notBlank(loginUrl)) {
                return;
            }
            loginUrl = app.config().loginUrl();
        }
    });
}
 

import act.app.App; //导入依赖的package包/类
@Override
protected void initialized() {
    App app = App.instance();

    Class rawType = spec.rawType();
    dao = app.dbServiceManager().dao(rawType);

    querySpec = S.string(options.get(KEY_USER_KEY));
    if (S.blank(querySpec)) {
        querySpec = AAAConfig.user.key.get();
    }
}