| 349 | |
| 350 | case localErr == leveldb.ErrNotFound: |
| 351 | return nil, nil // Not found in either store |
| 352 | |
| 353 | default: |
| 354 | return nil, fmt.Errorf("ipfs error: %v, local error: %v", ipfsErr, localErr) |
| 355 | } |
| 356 | |
| 357 | if value != nil { |
| 358 | db.cache.Set(key, value, 0) |
| 359 | } |
| 360 | return value, nil |
| 361 | } |
| 362 | |
| 363 | func (db *DB) Delete(key []byte) error { |
| 364 | var wg sync.WaitGroup |
| 365 | var localErr, ipfsErr error |
| 366 | wg.Add(2) |
| 367 | |
| 368 | go func() { |
| 369 | defer wg.Done() |
| 370 | localErr = db.localDB.Delete(key, nil) |
| 371 | _ = db.localDB.Delete(append([]byte("_meta:"), key...), nil) // Delete meta |
| 372 | }() |
| 373 | |
| 374 | go func() { |
| 375 | defer wg.Done() |
| 376 | ipfsErr = db.ipfsDB.Delete(db.ctx, key) |
| 377 | _ = db.ipfsDB.Delete(db.ctx, append([]byte("_meta:"), key...)) // Delete meta |
| 378 | }() |