external/fastocloud_admin
1
0
Fork 0
mirror of https://github.com/fastogt/fastocloud_admin.git synced 2025-03-09 23:38:52 +00:00
Code Issues Releases Wiki Activity

To server

Browse source
This commit is contained in:
topilski 2019-09-19 15:54:53 -04:00
parent e111d76e74
commit b1fa6cd4ce
1 changed files with 9 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

10
scripts/import_subscribers_from_xtream.py
View file

@ -8,6 +8,7 @@ import mysql.connector
sys.path.append(os.path.join(os.path.dirname(__file__), '..'))
from app.common.subscriber.login.entry import SubscriberUser
from app.service.service import ServiceSettings
PROJECT_NAME = 'create_provider'
@ -17,16 +18,22 @@ if __name__ == '__main__':
parser.add_argument('--mysql_host', help='MySQL host', default='localhost')
parser.add_argument('--mysql_user', help='MySQL username', default='')
parser.add_argument('--mysql_password', help='MySQL password', default='')
parser.add_argument('--server_id', help='Server ID', default='')
argv = parser.parse_args()
mysql_host = argv.mysql_host
mysql_user = argv.mysql_user
mysql_password = argv.mysql_password
server_id = argv.server_id
mongo = connect(host=argv.mongo_uri)
if not mongo:
sys.exit(1)
server = ServiceSettings.objects(id=server_id).first()
if server:
sys.exit(1)
mydb = mysql.connector.connect(
host=mysql_host,
user=mysql_user,
@ -44,6 +51,7 @@ if __name__ == '__main__':
for sql_entry in myresult:
new_user = SubscriberUser.make_subscriber(email=sql_entry['username'], password=sql_entry['password'], country='US')
new_user.save()
new_user.add_server(server)
server.add_subscriber(new_user)
mydb.close()