from metaapi_cloud_sdk import MetaApi, CopyFactory

token = '...'
metaapi = MetaApi(token=token)
copy_factory = CopyFactory(token=token)

# retrieve MetaApi MetaTrader accounts with CopyFactory as application field value
# master account must have PROVIDER value in copyFactoryRoles
master_metaapi_account = await metaapi.metatrader_account_api.get_account(account_id='masterMetaapiAccountId')
if (master_metaapi_account is None) or master_metaapi_account.copy_factory_roles is None or 'PROVIDER' not \
        in master_metaapi_account.copy_factory_roles:
    raise Exception('Please specify PROVIDER copyFactoryRoles value in your MetaApi '
                    'account in order to use it in CopyFactory API')
# slave account must have SUBSCRIBER value in copyFactoryRoles
slave_metaapi_account = await metaapi.metatrader_account_api.get_account(account_id='slaveMetaapiAccountId')
if (slave_metaapi_account is None) or slave_metaapi_account.copy_factory_roles is None or 'SUBSCRIBER' not \
        in slave_metaapi_account.copy_factory_roles:
    raise Exception('Please specify SUBSCRIBER copyFactoryRoles value in your MetaApi '
                    'account in order to use it in CopyFactory API')

configuration_api = copy_factory.configuration_api

# create a strategy being copied
strategy_id = await configuration_api.generate_strategy_id()
await configuration_api.update_strategy(id=strategy_id['id'], strategy={
    'name': 'Test strategy',
    'description': 'Some useful description about your strategy',
    'accountId': master_metaapi_account.id,
    'maxTradeRisk': 0.1,
    'stopOutRisk': {
        'value': 0.4,
        'startTime': '2020-08-24T00:00:00.000Z'
    },
    'timeSettings': {
        'lifetimeInHours': 192,
        'openingIntervalInMinutes': 5
    }
})

# subscribe slave CopyFactory accounts to the strategy
await configuration_api.update_subscriber(slave_metaapi_account.id, {
    'name': 'Demo account',
    'subscriptions': [
        {
            'strategyId': strategy_id['id'],
            'multiplier': 1
        }
    ]
})

# retrieve list of strategies
print(await configuration_api.get_strategies())

# retrieve list of provider portfolios
print(await configuration_api.get_portfolio_strategies())

# retrieve list of subscribers
print(await configuration_api.get_subscribers())

history_api = copy_factory.history_api

# retrieve trading history, please note that this method support pagination and limits number of records
print(await history_api.get_provided_transactions(time_from=datetime.fromisoformat('2020-08-01'),
    time_till=datetime.fromisoformat('2020-09-01')))

history_api = copy_factory.history_api

# retrieve trading history, please note that this method support pagination and limits number of records
print(await history_api.get_subscription_transactions(time_from=datetime.fromisoformat('2020-08-01'),
    time_till=datetime.fromisoformat('2020-09-01')))

account_id = '...' # CopyFactory account id

# resynchronize all strategies
await copy_factory.trading_api.resynchronize(account_id=account_id)

# resynchronize specific strategy
await copy_factory.trading_api.resynchronize(account_id=account_id, strategy_ids=['ABCD'])

trading_api = copy_factory.trading_api
signal_id = trading_api.generate_signal_id()

# add trading signal
await trading_api.update_external_signal(strategy_id=strategy_id, signal_id=signal_id, signal={
    'symbol': 'EURUSD',
    'type': 'POSITION_TYPE_BUY',
    'time': datetime.now(),
    'volume': 0.01
})

# remove signal
await trading_api.remove_external_signal(strategy_id=strategy_id, signal_id=signal_id, signal={
    'time': datetime.now()
})

subscriber_id = '...' # CopyFactory subscriber id

# retrieve trading signals
print(await copy_factory.trading_api.get_trading_signals(subscriber_id))

trading_api = copy_factory.trading_api
account_id = '...' # CopyFactory account id
strategy_id = '...' # CopyFactory strategy id

# retrieve list of strategy stopouts
print(await trading_api.get_stopouts(account_id=account_id))

# reset a stopout so that subscription can continue
await trading_api.reset_stopouts(account_id=account_id, strategy_id=strategy_id, reason='daily-equity')

trading_api = copy_factory.trading_api
account_id = '...' # CopyFactory account id

# retrieve slave trading log
print(await trading_api.get_user_log(account_id))

# retrieve paginated slave trading log by time range
print(await trading_api.get_user_log(account_id, datetime.fromtimestamp(datetime.now().timestamp() - 24 * 60 * 60), None, 20, 10))