#246

Committed 08 Apr 2025 06:29AM UTC coverage: 59.356% (-6.0%) from 65.404%

Build # #246

Build Type

push

Committed by

Commit Message

Add timeout. Extract interruptAfterDelay. Ignore testRoundtrip_configurationsGiven_lmdbCreatedExportedAndRunFindSecretsFile for now.

Run Details

1050 of 1769 relevant lines covered (59.36%)

0.59 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/src/main/java/net/ladenthin/bitcoinaddressfinder/LMDBToAddressFile.java

// @formatter:off
/**
 * Copyright 2020 Bernard Ladenthin bernard.ladenthin@gmail.com
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *    http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 *
 */
// @formatter:on
package net.ladenthin.bitcoinaddressfinder;

import net.ladenthin.bitcoinaddressfinder.persistence.PersistenceUtils;
import net.ladenthin.bitcoinaddressfinder.persistence.lmdb.LMDBPersistence;
import org.bitcoinj.core.NetworkParameters;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.io.File;
import java.io.IOException;
import java.util.concurrent.atomic.AtomicBoolean;
import net.ladenthin.bitcoinaddressfinder.configuration.CLMDBToAddressFile;

public class LMDBToAddressFile implements Runnable, Interruptable {

    private final Logger logger = LoggerFactory.getLogger(LMDBToAddressFile.class);

    private final CLMDBToAddressFile lmdbToAddressFile;

    private LMDBPersistence persistence;
    
    private final AtomicBoolean shouldRun = new AtomicBoolean(true);

    public LMDBToAddressFile(CLMDBToAddressFile lmdbToAddressFile) {
        this.lmdbToAddressFile = lmdbToAddressFile;
    }

    @Override
    public void run() {
        final NetworkParameters networkParameters = new NetworkParameterFactory().getOrCreate();
        
        PersistenceUtils persistenceUtils = new PersistenceUtils(networkParameters);
        persistence = new LMDBPersistence(lmdbToAddressFile.lmdbConfigurationReadOnly, persistenceUtils);
        persistence.init();
        try {
            logger.info("writeAllAmounts ...");
            File addressesFile = new File(lmdbToAddressFile.addressesFile);
            // delete before write all addresses
            addressesFile.delete();
            persistence.writeAllAmountsToAddressFile(addressesFile, lmdbToAddressFile.addressFileOutputFormat, shouldRun);
            logger.info("writeAllAmounts done");
        } catch (IOException e) {
            throw new RuntimeException(e);
        } finally {
            persistence.close();
        }
    }

    @Override
    public void interrupt() {
        shouldRun.set(false);
    }
}

1	// @formatter:off
2	/**
3	* Copyright 2020 Bernard Ladenthin bernard.ladenthin@gmail.com
4	*
5	* Licensed under the Apache License, Version 2.0 (the "License");
6	* you may not use this file except in compliance with the License.
7	* You may obtain a copy of the License at
8	*
9	* http://www.apache.org/licenses/LICENSE-2.0
10	*
11	* Unless required by applicable law or agreed to in writing, software
12	* distributed under the License is distributed on an "AS IS" BASIS,
13	* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14	* See the License for the specific language governing permissions and
15	* limitations under the License.
16	*
17	*/
18	// @formatter:on
19	package net.ladenthin.bitcoinaddressfinder;
20
21	import net.ladenthin.bitcoinaddressfinder.persistence.PersistenceUtils;
22	import net.ladenthin.bitcoinaddressfinder.persistence.lmdb.LMDBPersistence;
23	import org.bitcoinj.core.NetworkParameters;
24	import org.slf4j.Logger;
25	import org.slf4j.LoggerFactory;
26
27	import java.io.File;
28	import java.io.IOException;
29	import java.util.concurrent.atomic.AtomicBoolean;
30	import net.ladenthin.bitcoinaddressfinder.configuration.CLMDBToAddressFile;
31
32	public class LMDBToAddressFile implements Runnable, Interruptable {
33
34	private final Logger logger = LoggerFactory.getLogger(LMDBToAddressFile.class);	×
35
36	private final CLMDBToAddressFile lmdbToAddressFile;
37
38	private LMDBPersistence persistence;
39
40	private final AtomicBoolean shouldRun = new AtomicBoolean(true);	×
41
42	public LMDBToAddressFile(CLMDBToAddressFile lmdbToAddressFile) {	×
43	this.lmdbToAddressFile = lmdbToAddressFile;	×
44	}	×
45
46	@Override
47	public void run() {
48	final NetworkParameters networkParameters = new NetworkParameterFactory().getOrCreate();	×
49
50	PersistenceUtils persistenceUtils = new PersistenceUtils(networkParameters);	×
51	persistence = new LMDBPersistence(lmdbToAddressFile.lmdbConfigurationReadOnly, persistenceUtils);	×
52	persistence.init();	×
53	try {
54	logger.info("writeAllAmounts ...");	×
55	File addressesFile = new File(lmdbToAddressFile.addressesFile);	×
56	// delete before write all addresses
57	addressesFile.delete();	×
58	persistence.writeAllAmountsToAddressFile(addressesFile, lmdbToAddressFile.addressFileOutputFormat, shouldRun);	×
59	logger.info("writeAllAmounts done");	×
60	} catch (IOException e) {	×
61	throw new RuntimeException(e);	×
62	} finally {
63	persistence.close();	×
64	}
65	}	×
66
67	@Override
68	public void interrupt() {
69	shouldRun.set(false);	×
70	}	×
71	}

bernardladenthin / BitcoinAddressFinder / #246

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous