Omnibus commited on
Commit
d859eb0
·
1 Parent(s): ca37e99

Update mychain.py

Browse files
Files changed (1) hide show
  1. mychain.py +29 -24
mychain.py CHANGED
@@ -7,6 +7,7 @@ from huggingface_hub import (upload_file,HfApi)
7
  token_self = os.environ['HF_TOKEN']
8
  api = HfApi(token=token_self)
9
  chain_d="chain1.json"
 
10
 
11
 
12
  class Blockchain:
@@ -157,8 +158,8 @@ class Blockchain:
157
  class MyChainSend:
158
 
159
  def __init__(self,chain_load,load=None,create=None):
160
- global main_chain
161
- main_chain=chain_load
162
 
163
  self.pending_transactions = []
164
  if load == None or load=="":
@@ -174,11 +175,11 @@ class MyChainSend:
174
  self.create_block(proof=1, previous_hash='0',chain_n=create)
175
  def create_block(self, balance, proof, previous_hash,prev_block=None,chain_r=None,chain_n=None):
176
  if chain_r=="" or chain_r==None:
177
- chain_r=f"{main_chain.split('datasets/',1)[1].split('/raw',1)[0]}"
178
  if chain_n !="" and chain_n !=None:
179
- chain_n = f"{main_chain.split('main/',1)[1]}{chain_n}.json"
180
  if chain_n=="" or chain_n==None:
181
- chain_n=chain_d
182
  #prev_block = len(blockchain.chain)-1
183
  #previous_block = blockchain.chain[prev_block]
184
  block = {'index': len(self.chain) + 1,
@@ -193,17 +194,17 @@ class MyChainSend:
193
  self.pending_transactions = []
194
  self.chain.append(block)
195
  json_object = json.dumps(self.chain, indent=4)
196
- with open("tmp.json", "w") as outfile:
197
  outfile.write(json_object)
198
  try:
199
  api.upload_file(
200
- path_or_fileobj="tmp.json",
201
  path_in_repo=chain_n,
202
  repo_id=chain_r,
203
  token=token_self,
204
  repo_type="dataset",
205
  )
206
- os.remove("tmp.json")
207
 
208
  except Exception as e:
209
  print(e)
@@ -371,7 +372,7 @@ class MyChainRec:
371
  if chain_n !="" and chain_n !=None:
372
  chain_n = f"{main_chain_rec.split('main/',1)[1]}{chain_n}.json"
373
  if chain_n=="" or chain_n==None:
374
- chain_n=chain_d
375
  #prev_block = len(blockchain.chain)-1
376
  #previous_block = blockchain.chain[prev_block]
377
  block = {'index': len(self.chain) + 1,
@@ -385,17 +386,17 @@ class MyChainRec:
385
  self.pending_transactions = []
386
  self.chain.append(block)
387
  json_object = json.dumps(self.chain, indent=4)
388
- with open("tmp1.json", "w") as outfile:
389
  outfile.write(json_object)
390
  try:
391
  api.upload_file(
392
- path_or_fileobj="tmp1.json",
393
  path_in_repo=chain_n,
394
  repo_id=chain_r,
395
  token=token_self,
396
  repo_type="dataset",
397
  )
398
- os.remove("tmp1.json")
399
 
400
  except Exception as e:
401
  print(e)
@@ -491,9 +492,9 @@ class MyChainRec:
491
 
492
  class MyChainTrans:
493
 
494
- def __init__(self,chain_load,block_trans,load=None,create=None):
495
- global main_chain
496
- main_chain=chain_load
497
 
498
  self.pending_transactions = []
499
  if load == None or load=="":
@@ -507,17 +508,20 @@ class MyChainTrans:
507
  self.chain = []
508
  self.pending_transactions = []
509
  self.create_block(proof=1, previous_hash='0',chain_n=create)
510
- def create_block(self, balance, proof, previous_hash,chain_r=None,chain_n=None):
511
  if chain_r=="" or chain_r==None:
512
- chain_r=f"{main_chain.split('datasets/',1)[1].split('/raw',1)[0]}"
513
  if chain_n !="" and chain_n !=None:
514
- chain_n = f"{main_chain.split('main/',1)[1]}{chain_n}.json"
515
  if chain_n=="" or chain_n==None:
516
- chain_n=chain_d
517
- block = {'block':blockchain.print_previous_block,
518
- 'index': len(self.chain) + 1,
 
519
  'timestamp': str(datetime.datetime.now()),
 
520
  'transactions': self.pending_transactions,
 
521
  'proof': proof,
522
  'previous_hash': previous_hash}
523
  if self.block_valid(block) == True:
@@ -525,17 +529,17 @@ class MyChainTrans:
525
  self.pending_transactions = []
526
  self.chain.append(block)
527
  json_object = json.dumps(self.chain, indent=4)
528
- with open("tmp.json", "w") as outfile:
529
  outfile.write(json_object)
530
  try:
531
  api.upload_file(
532
- path_or_fileobj="tmp.json",
533
  path_in_repo=chain_n,
534
  repo_id=chain_r,
535
  token=token_self,
536
  repo_type="dataset",
537
  )
538
- os.remove("tmp.json")
539
 
540
  except Exception as e:
541
  print(e)
@@ -600,6 +604,7 @@ class MyChainTrans:
600
  return out
601
 
602
  def chain_valid(self, chain):
 
603
  previous_block = chain[0]
604
  block_index = 1
605
  out=True
 
7
  token_self = os.environ['HF_TOKEN']
8
  api = HfApi(token=token_self)
9
  chain_d="chain1.json"
10
+ chain_t="trans1.json"
11
 
12
 
13
  class Blockchain:
 
158
  class MyChainSend:
159
 
160
  def __init__(self,chain_load,load=None,create=None):
161
+ global main_chain_send
162
+ main_chain_send=chain_load
163
 
164
  self.pending_transactions = []
165
  if load == None or load=="":
 
175
  self.create_block(proof=1, previous_hash='0',chain_n=create)
176
  def create_block(self, balance, proof, previous_hash,prev_block=None,chain_r=None,chain_n=None):
177
  if chain_r=="" or chain_r==None:
178
+ chain_r=f"{main_chain_send.split('datasets/',1)[1].split('/raw',1)[0]}"
179
  if chain_n !="" and chain_n !=None:
180
+ chain_n = f"{main_chain_send.split('main/',1)[1]}{chain_n}.json"
181
  if chain_n=="" or chain_n==None:
182
+ chain_n="error_send.json"
183
  #prev_block = len(blockchain.chain)-1
184
  #previous_block = blockchain.chain[prev_block]
185
  block = {'index': len(self.chain) + 1,
 
194
  self.pending_transactions = []
195
  self.chain.append(block)
196
  json_object = json.dumps(self.chain, indent=4)
197
+ with open("tmp_send.json", "w") as outfile:
198
  outfile.write(json_object)
199
  try:
200
  api.upload_file(
201
+ path_or_fileobj="tmp_send.json",
202
  path_in_repo=chain_n,
203
  repo_id=chain_r,
204
  token=token_self,
205
  repo_type="dataset",
206
  )
207
+ os.remove("tmp_send.json")
208
 
209
  except Exception as e:
210
  print(e)
 
372
  if chain_n !="" and chain_n !=None:
373
  chain_n = f"{main_chain_rec.split('main/',1)[1]}{chain_n}.json"
374
  if chain_n=="" or chain_n==None:
375
+ chain_n="error_rec.json"
376
  #prev_block = len(blockchain.chain)-1
377
  #previous_block = blockchain.chain[prev_block]
378
  block = {'index': len(self.chain) + 1,
 
386
  self.pending_transactions = []
387
  self.chain.append(block)
388
  json_object = json.dumps(self.chain, indent=4)
389
+ with open("tmp_rec.json", "w") as outfile:
390
  outfile.write(json_object)
391
  try:
392
  api.upload_file(
393
+ path_or_fileobj="tmp_rec.json",
394
  path_in_repo=chain_n,
395
  repo_id=chain_r,
396
  token=token_self,
397
  repo_type="dataset",
398
  )
399
+ os.remove("tmp_rec.json")
400
 
401
  except Exception as e:
402
  print(e)
 
492
 
493
  class MyChainTrans:
494
 
495
+ def __init__(self,chain_load,load=None,create=None):
496
+ global main_chain_trans
497
+ main_chain_trans=chain_load
498
 
499
  self.pending_transactions = []
500
  if load == None or load=="":
 
508
  self.chain = []
509
  self.pending_transactions = []
510
  self.create_block(proof=1, previous_hash='0',chain_n=create)
511
+ def create_block(self, balance, proof, previous_hash,prev_block=None,chain_r=None,chain_n=None):
512
  if chain_r=="" or chain_r==None:
513
+ chain_r=f"{main_chain_trans.split('datasets/',1)[1].split('/raw',1)[0]}"
514
  if chain_n !="" and chain_n !=None:
515
+ chain_n = f"{main_chain_trans.split('main/',1)[1]}{chain_t}.json"
516
  if chain_n=="" or chain_n==None:
517
+ chain_n="error_send.json"
518
+ #prev_block = len(blockchain.chain)-1
519
+ #previous_block = blockchain.chain[prev_block]
520
+ block = {'index': len(self.chain) + 1,
521
  'timestamp': str(datetime.datetime.now()),
522
+ 'block': len(blockchain.chain)+1,
523
  'transactions': self.pending_transactions,
524
+ 'balance': balance,
525
  'proof': proof,
526
  'previous_hash': previous_hash}
527
  if self.block_valid(block) == True:
 
529
  self.pending_transactions = []
530
  self.chain.append(block)
531
  json_object = json.dumps(self.chain, indent=4)
532
+ with open("tmp_trans.json", "w") as outfile:
533
  outfile.write(json_object)
534
  try:
535
  api.upload_file(
536
+ path_or_fileobj="tmp_trans.json",
537
  path_in_repo=chain_n,
538
  repo_id=chain_r,
539
  token=token_self,
540
  repo_type="dataset",
541
  )
542
+ os.remove("tmp_trans.json")
543
 
544
  except Exception as e:
545
  print(e)
 
604
  return out
605
 
606
  def chain_valid(self, chain):
607
+
608
  previous_block = chain[0]
609
  block_index = 1
610
  out=True