Second pre-release update
[novacoin.git] / src / wallet.cpp
1 // Copyright (c) 2009-2010 Satoshi Nakamoto
2 // Copyright (c) 2009-2012 The Bitcoin developers
3 // Distributed under the MIT/X11 software license, see the accompanying
4 // file COPYING or http://www.opensource.org/licenses/mit-license.php.
5
6 #include "txdb.h"
7 #include "wallet.h"
8 #include "walletdb.h"
9 #include "crypter.h"
10 #include "ui_interface.h"
11 #include "base58.h"
12 #include "kernel.h"
13 #include "coincontrol.h"
14 #include <boost/algorithm/string/replace.hpp>
15
16 using namespace std;
17 extern int nStakeMaxAge;
18
19
20 //////////////////////////////////////////////////////////////////////////////
21 //
22 // mapWallet
23 //
24
25 struct CompareValueOnly
26 {
27     bool operator()(const pair<int64, pair<const CWalletTx*, unsigned int> >& t1,
28                     const pair<int64, pair<const CWalletTx*, unsigned int> >& t2) const
29     {
30         return t1.first < t2.first;
31     }
32 };
33
34 CPubKey CWallet::GenerateNewKey()
35 {
36     bool fCompressed = CanSupportFeature(FEATURE_COMPRPUBKEY); // default to compressed public keys if we want 0.6.0 wallets
37
38     RandAddSeedPerfmon();
39     CKey key;
40     key.MakeNewKey(fCompressed);
41
42     // Compressed public keys were introduced in version 0.6.0
43     if (fCompressed)
44         SetMinVersion(FEATURE_COMPRPUBKEY);
45
46     CPubKey pubkey = key.GetPubKey();
47
48     // Create new metadata
49     int64 nCreationTime = GetTime();
50     mapKeyMetadata[pubkey.GetID()] = CKeyMetadata(nCreationTime);
51     if (!nTimeFirstKey || nCreationTime < nTimeFirstKey)
52         nTimeFirstKey = nCreationTime;
53
54     if (!AddKey(key))
55         throw std::runtime_error("CWallet::GenerateNewKey() : AddKey failed");
56     return key.GetPubKey();
57 }
58
59 bool CWallet::AddKey(const CKey& key)
60 {
61     CPubKey pubkey = key.GetPubKey();
62
63     if (!CCryptoKeyStore::AddKey(key))
64         return false;
65     if (!fFileBacked)
66         return true;
67     if (!IsCrypted())
68         return CWalletDB(strWalletFile).WriteKey(pubkey, key.GetPrivKey(), mapKeyMetadata[pubkey.GetID()]);
69     return true;
70 }
71
72 bool CWallet::AddCryptedKey(const CPubKey &vchPubKey, const vector<unsigned char> &vchCryptedSecret)
73 {
74     if (!CCryptoKeyStore::AddCryptedKey(vchPubKey, vchCryptedSecret))
75         return false;
76     if (!fFileBacked)
77         return true;
78     {
79         LOCK(cs_wallet);
80         if (pwalletdbEncryption)
81             return pwalletdbEncryption->WriteCryptedKey(vchPubKey, vchCryptedSecret, mapKeyMetadata[vchPubKey.GetID()]);
82         else
83             return CWalletDB(strWalletFile).WriteCryptedKey(vchPubKey, vchCryptedSecret, mapKeyMetadata[vchPubKey.GetID()]);
84     }
85     return false;
86 }
87
88 bool CWallet::LoadKeyMetadata(const CPubKey &pubkey, const CKeyMetadata &meta)
89 {
90     if (meta.nCreateTime && (!nTimeFirstKey || meta.nCreateTime < nTimeFirstKey))
91         nTimeFirstKey = meta.nCreateTime;
92
93     mapKeyMetadata[pubkey.GetID()] = meta;
94     return true;
95 }
96
97 bool CWallet::AddCScript(const CScript& redeemScript)
98 {
99     if (!CCryptoKeyStore::AddCScript(redeemScript))
100         return false;
101     if (!fFileBacked)
102         return true;
103     return CWalletDB(strWalletFile).WriteCScript(Hash160(redeemScript), redeemScript);
104 }
105
106 // ppcoin: optional setting to unlock wallet for block minting only;
107 //         serves to disable the trivial sendmoney when OS account compromised
108 bool fWalletUnlockMintOnly = false;
109
110 bool CWallet::Unlock(const SecureString& strWalletPassphrase)
111 {
112     if (!IsLocked())
113         return false;
114
115     CCrypter crypter;
116     CKeyingMaterial vMasterKey;
117
118     {
119         LOCK(cs_wallet);
120         BOOST_FOREACH(const MasterKeyMap::value_type& pMasterKey, mapMasterKeys)
121         {
122             if(!crypter.SetKeyFromPassphrase(strWalletPassphrase, pMasterKey.second.vchSalt, pMasterKey.second.nDeriveIterations, pMasterKey.second.nDerivationMethod))
123                 return false;
124             if (!crypter.Decrypt(pMasterKey.second.vchCryptedKey, vMasterKey))
125                 return false;
126             if (CCryptoKeyStore::Unlock(vMasterKey))
127                 return true;
128         }
129     }
130     return false;
131 }
132
133 bool CWallet::ChangeWalletPassphrase(const SecureString& strOldWalletPassphrase, const SecureString& strNewWalletPassphrase)
134 {
135     bool fWasLocked = IsLocked();
136
137     {
138         LOCK(cs_wallet);
139         Lock();
140
141         CCrypter crypter;
142         CKeyingMaterial vMasterKey;
143         BOOST_FOREACH(MasterKeyMap::value_type& pMasterKey, mapMasterKeys)
144         {
145             if(!crypter.SetKeyFromPassphrase(strOldWalletPassphrase, pMasterKey.second.vchSalt, pMasterKey.second.nDeriveIterations, pMasterKey.second.nDerivationMethod))
146                 return false;
147             if (!crypter.Decrypt(pMasterKey.second.vchCryptedKey, vMasterKey))
148                 return false;
149             if (CCryptoKeyStore::Unlock(vMasterKey))
150             {
151                 int64 nStartTime = GetTimeMillis();
152                 crypter.SetKeyFromPassphrase(strNewWalletPassphrase, pMasterKey.second.vchSalt, pMasterKey.second.nDeriveIterations, pMasterKey.second.nDerivationMethod);
153                 pMasterKey.second.nDeriveIterations = pMasterKey.second.nDeriveIterations * (100 / ((double)(GetTimeMillis() - nStartTime)));
154
155                 nStartTime = GetTimeMillis();
156                 crypter.SetKeyFromPassphrase(strNewWalletPassphrase, pMasterKey.second.vchSalt, pMasterKey.second.nDeriveIterations, pMasterKey.second.nDerivationMethod);
157                 pMasterKey.second.nDeriveIterations = (pMasterKey.second.nDeriveIterations + pMasterKey.second.nDeriveIterations * 100 / ((double)(GetTimeMillis() - nStartTime))) / 2;
158
159                 if (pMasterKey.second.nDeriveIterations < 25000)
160                     pMasterKey.second.nDeriveIterations = 25000;
161
162                 printf("Wallet passphrase changed to an nDeriveIterations of %i\n", pMasterKey.second.nDeriveIterations);
163
164                 if (!crypter.SetKeyFromPassphrase(strNewWalletPassphrase, pMasterKey.second.vchSalt, pMasterKey.second.nDeriveIterations, pMasterKey.second.nDerivationMethod))
165                     return false;
166                 if (!crypter.Encrypt(vMasterKey, pMasterKey.second.vchCryptedKey))
167                     return false;
168                 CWalletDB(strWalletFile).WriteMasterKey(pMasterKey.first, pMasterKey.second);
169                 if (fWasLocked)
170                     Lock();
171                 return true;
172             }
173         }
174     }
175
176     return false;
177 }
178
179 void CWallet::SetBestChain(const CBlockLocator& loc)
180 {
181     CWalletDB walletdb(strWalletFile);
182     walletdb.WriteBestBlock(loc);
183 }
184
185 // This class implements an addrIncoming entry that causes pre-0.4
186 // clients to crash on startup if reading a private-key-encrypted wallet.
187 class CCorruptAddress
188 {
189 public:
190     IMPLEMENT_SERIALIZE
191     (
192         if (nType & SER_DISK)
193             READWRITE(nVersion);
194     )
195 };
196
197 bool CWallet::SetMinVersion(enum WalletFeature nVersion, CWalletDB* pwalletdbIn, bool fExplicit)
198 {
199     if (nWalletVersion >= nVersion)
200         return true;
201
202     // when doing an explicit upgrade, if we pass the max version permitted, upgrade all the way
203     if (fExplicit && nVersion > nWalletMaxVersion)
204             nVersion = FEATURE_LATEST;
205
206     nWalletVersion = nVersion;
207
208     if (nVersion > nWalletMaxVersion)
209         nWalletMaxVersion = nVersion;
210
211     if (fFileBacked)
212     {
213         CWalletDB* pwalletdb = pwalletdbIn ? pwalletdbIn : new CWalletDB(strWalletFile);
214         if (nWalletVersion >= 40000)
215         {
216             // Versions prior to 0.4.0 did not support the "minversion" record.
217             // Use a CCorruptAddress to make them crash instead.
218             CCorruptAddress corruptAddress;
219             pwalletdb->WriteSetting("addrIncoming", corruptAddress);
220         }
221         if (nWalletVersion > 40000)
222             pwalletdb->WriteMinVersion(nWalletVersion);
223         if (!pwalletdbIn)
224             delete pwalletdb;
225     }
226
227     return true;
228 }
229
230 bool CWallet::SetMaxVersion(int nVersion)
231 {
232     // cannot downgrade below current version
233     if (nWalletVersion > nVersion)
234         return false;
235
236     nWalletMaxVersion = nVersion;
237
238     return true;
239 }
240
241 bool CWallet::EncryptWallet(const SecureString& strWalletPassphrase)
242 {
243     if (IsCrypted())
244         return false;
245
246     CKeyingMaterial vMasterKey;
247     RandAddSeedPerfmon();
248
249     vMasterKey.resize(WALLET_CRYPTO_KEY_SIZE);
250     RAND_bytes(&vMasterKey[0], WALLET_CRYPTO_KEY_SIZE);
251
252     CMasterKey kMasterKey(nDerivationMethodIndex);
253
254     RandAddSeedPerfmon();
255     kMasterKey.vchSalt.resize(WALLET_CRYPTO_SALT_SIZE);
256     RAND_bytes(&kMasterKey.vchSalt[0], WALLET_CRYPTO_SALT_SIZE);
257
258     CCrypter crypter;
259     int64 nStartTime = GetTimeMillis();
260     crypter.SetKeyFromPassphrase(strWalletPassphrase, kMasterKey.vchSalt, 25000, kMasterKey.nDerivationMethod);
261     kMasterKey.nDeriveIterations = 2500000 / ((double)(GetTimeMillis() - nStartTime));
262
263     nStartTime = GetTimeMillis();
264     crypter.SetKeyFromPassphrase(strWalletPassphrase, kMasterKey.vchSalt, kMasterKey.nDeriveIterations, kMasterKey.nDerivationMethod);
265     kMasterKey.nDeriveIterations = (kMasterKey.nDeriveIterations + kMasterKey.nDeriveIterations * 100 / ((double)(GetTimeMillis() - nStartTime))) / 2;
266
267     if (kMasterKey.nDeriveIterations < 25000)
268         kMasterKey.nDeriveIterations = 25000;
269
270     printf("Encrypting Wallet with an nDeriveIterations of %i\n", kMasterKey.nDeriveIterations);
271
272     if (!crypter.SetKeyFromPassphrase(strWalletPassphrase, kMasterKey.vchSalt, kMasterKey.nDeriveIterations, kMasterKey.nDerivationMethod))
273         return false;
274     if (!crypter.Encrypt(vMasterKey, kMasterKey.vchCryptedKey))
275         return false;
276
277     {
278         LOCK(cs_wallet);
279         mapMasterKeys[++nMasterKeyMaxID] = kMasterKey;
280         if (fFileBacked)
281         {
282             pwalletdbEncryption = new CWalletDB(strWalletFile);
283             if (!pwalletdbEncryption->TxnBegin())
284                 return false;
285             pwalletdbEncryption->WriteMasterKey(nMasterKeyMaxID, kMasterKey);
286         }
287
288         if (!EncryptKeys(vMasterKey))
289         {
290             if (fFileBacked)
291                 pwalletdbEncryption->TxnAbort();
292             exit(1); //We now probably have half of our keys encrypted in memory, and half not...die and let the user reload their unencrypted wallet.
293         }
294
295         // Encryption was introduced in version 0.4.0
296         SetMinVersion(FEATURE_WALLETCRYPT, pwalletdbEncryption, true);
297
298         if (fFileBacked)
299         {
300             if (!pwalletdbEncryption->TxnCommit())
301                 exit(1); //We now have keys encrypted in memory, but no on disk...die to avoid confusion and let the user reload their unencrypted wallet.
302
303             delete pwalletdbEncryption;
304             pwalletdbEncryption = NULL;
305         }
306
307         Lock();
308         Unlock(strWalletPassphrase);
309         NewKeyPool();
310         Lock();
311
312         // Need to completely rewrite the wallet file; if we don't, bdb might keep
313         // bits of the unencrypted private key in slack space in the database file.
314         CDB::Rewrite(strWalletFile);
315
316     }
317     NotifyStatusChanged(this);
318
319     return true;
320 }
321
322 int64 CWallet::IncOrderPosNext(CWalletDB *pwalletdb)
323 {
324     int64 nRet = nOrderPosNext++;
325     if (pwalletdb) {
326         pwalletdb->WriteOrderPosNext(nOrderPosNext);
327     } else {
328         CWalletDB(strWalletFile).WriteOrderPosNext(nOrderPosNext);
329     }
330     return nRet;
331 }
332
333 CWallet::TxItems CWallet::OrderedTxItems(std::list<CAccountingEntry>& acentries, std::string strAccount)
334 {
335     CWalletDB walletdb(strWalletFile);
336
337     // First: get all CWalletTx and CAccountingEntry into a sorted-by-order multimap.
338     TxItems txOrdered;
339
340     // Note: maintaining indices in the database of (account,time) --> txid and (account, time) --> acentry
341     // would make this much faster for applications that do this a lot.
342     for (map<uint256, CWalletTx>::iterator it = mapWallet.begin(); it != mapWallet.end(); ++it)
343     {
344         CWalletTx* wtx = &((*it).second);
345         txOrdered.insert(make_pair(wtx->nOrderPos, TxPair(wtx, (CAccountingEntry*)0)));
346     }
347     acentries.clear();
348     walletdb.ListAccountCreditDebit(strAccount, acentries);
349     BOOST_FOREACH(CAccountingEntry& entry, acentries)
350     {
351         txOrdered.insert(make_pair(entry.nOrderPos, TxPair((CWalletTx*)0, &entry)));
352     }
353
354     return txOrdered;
355 }
356
357 void CWallet::WalletUpdateSpent(const CTransaction &tx)
358 {
359     // Anytime a signature is successfully verified, it's proof the outpoint is spent.
360     // Update the wallet spent flag if it doesn't know due to wallet.dat being
361     // restored from backup or the user making copies of wallet.dat.
362     {
363         LOCK(cs_wallet);
364         BOOST_FOREACH(const CTxIn& txin, tx.vin)
365         {
366             map<uint256, CWalletTx>::iterator mi = mapWallet.find(txin.prevout.hash);
367             if (mi != mapWallet.end())
368             {
369                 CWalletTx& wtx = (*mi).second;
370                 if (txin.prevout.n >= wtx.vout.size())
371                     printf("WalletUpdateSpent: bad wtx %s\n", wtx.GetHash().ToString().c_str());
372                 else if (!wtx.IsSpent(txin.prevout.n) && IsMine(wtx.vout[txin.prevout.n]))
373                 {
374                     printf("WalletUpdateSpent found spent coin %snvc %s\n", FormatMoney(wtx.GetCredit()).c_str(), wtx.GetHash().ToString().c_str());
375                     wtx.MarkSpent(txin.prevout.n);
376                     wtx.WriteToDisk();
377                     NotifyTransactionChanged(this, txin.prevout.hash, CT_UPDATED);
378                 }
379             }
380         }
381     }
382 }
383
384 void CWallet::MarkDirty()
385 {
386     {
387         LOCK(cs_wallet);
388         BOOST_FOREACH(PAIRTYPE(const uint256, CWalletTx)& item, mapWallet)
389             item.second.MarkDirty();
390     }
391 }
392
393 bool CWallet::AddToWallet(const CWalletTx& wtxIn)
394 {
395     uint256 hash = wtxIn.GetHash();
396     {
397         LOCK(cs_wallet);
398         // Inserts only if not already there, returns tx inserted or tx found
399         pair<map<uint256, CWalletTx>::iterator, bool> ret = mapWallet.insert(make_pair(hash, wtxIn));
400         CWalletTx& wtx = (*ret.first).second;
401         wtx.BindWallet(this);
402         bool fInsertedNew = ret.second;
403         if (fInsertedNew)
404         {
405             wtx.nTimeReceived = GetAdjustedTime();
406             wtx.nOrderPos = IncOrderPosNext();
407
408             wtx.nTimeSmart = wtx.nTimeReceived;
409             if (wtxIn.hashBlock != 0)
410             {
411                 if (mapBlockIndex.count(wtxIn.hashBlock))
412                 {
413                     unsigned int latestNow = wtx.nTimeReceived;
414                     unsigned int latestEntry = 0;
415                     {
416                         // Tolerate times up to the last timestamp in the wallet not more than 5 minutes into the future
417                         int64 latestTolerated = latestNow + 300;
418                         std::list<CAccountingEntry> acentries;
419                         TxItems txOrdered = OrderedTxItems(acentries);
420                         for (TxItems::reverse_iterator it = txOrdered.rbegin(); it != txOrdered.rend(); ++it)
421                         {
422                             CWalletTx *const pwtx = (*it).second.first;
423                             if (pwtx == &wtx)
424                                 continue;
425                             CAccountingEntry *const pacentry = (*it).second.second;
426                             int64 nSmartTime;
427                             if (pwtx)
428                             {
429                                 nSmartTime = pwtx->nTimeSmart;
430                                 if (!nSmartTime)
431                                     nSmartTime = pwtx->nTimeReceived;
432                             }
433                             else
434                                 nSmartTime = pacentry->nTime;
435                             if (nSmartTime <= latestTolerated)
436                             {
437                                 latestEntry = nSmartTime;
438                                 if (nSmartTime > latestNow)
439                                     latestNow = nSmartTime;
440                                 break;
441                             }
442                         }
443                     }
444
445                     unsigned int& blocktime = mapBlockIndex[wtxIn.hashBlock]->nTime;
446                     wtx.nTimeSmart = std::max(latestEntry, std::min(blocktime, latestNow));
447                 }
448                 else
449                     printf("AddToWallet() : found %s in block %s not in index\n",
450                            wtxIn.GetHash().ToString().substr(0,10).c_str(),
451                            wtxIn.hashBlock.ToString().c_str());
452             }
453         }
454
455         bool fUpdated = false;
456         if (!fInsertedNew)
457         {
458             // Merge
459             if (wtxIn.hashBlock != 0 && wtxIn.hashBlock != wtx.hashBlock)
460             {
461                 wtx.hashBlock = wtxIn.hashBlock;
462                 fUpdated = true;
463             }
464             if (wtxIn.nIndex != -1 && (wtxIn.vMerkleBranch != wtx.vMerkleBranch || wtxIn.nIndex != wtx.nIndex))
465             {
466                 wtx.vMerkleBranch = wtxIn.vMerkleBranch;
467                 wtx.nIndex = wtxIn.nIndex;
468                 fUpdated = true;
469             }
470             if (wtxIn.fFromMe && wtxIn.fFromMe != wtx.fFromMe)
471             {
472                 wtx.fFromMe = wtxIn.fFromMe;
473                 fUpdated = true;
474             }
475             fUpdated |= wtx.UpdateSpent(wtxIn.vfSpent);
476         }
477
478         //// debug print
479         printf("AddToWallet %s  %s%s\n", wtxIn.GetHash().ToString().substr(0,10).c_str(), (fInsertedNew ? "new" : ""), (fUpdated ? "update" : ""));
480
481         // Write to disk
482         if (fInsertedNew || fUpdated)
483             if (!wtx.WriteToDisk())
484                 return false;
485 #ifndef QT_GUI
486         // If default receiving address gets used, replace it with a new one
487         CScript scriptDefaultKey;
488         scriptDefaultKey.SetDestination(vchDefaultKey.GetID());
489         BOOST_FOREACH(const CTxOut& txout, wtx.vout)
490         {
491             if (txout.scriptPubKey == scriptDefaultKey)
492             {
493                 CPubKey newDefaultKey;
494                 if (GetKeyFromPool(newDefaultKey, false))
495                 {
496                     SetDefaultKey(newDefaultKey);
497                     SetAddressBookName(vchDefaultKey.GetID(), "");
498                 }
499             }
500         }
501 #endif
502         // since AddToWallet is called directly for self-originating transactions, check for consumption of own coins
503         WalletUpdateSpent(wtx);
504
505         // Notify UI of new or updated transaction
506         NotifyTransactionChanged(this, hash, fInsertedNew ? CT_NEW : CT_UPDATED);
507
508         // notify an external script when a wallet transaction comes in or is updated
509         std::string strCmd = GetArg("-walletnotify", "");
510
511         if ( !strCmd.empty())
512         {
513             boost::replace_all(strCmd, "%s", wtxIn.GetHash().GetHex());
514             boost::thread t(runCommand, strCmd); // thread runs free
515         }
516
517     }
518     return true;
519 }
520
521 // Add a transaction to the wallet, or update it.
522 // pblock is optional, but should be provided if the transaction is known to be in a block.
523 // If fUpdate is true, existing transactions will be updated.
524 bool CWallet::AddToWalletIfInvolvingMe(const CTransaction& tx, const CBlock* pblock, bool fUpdate, bool fFindBlock)
525 {
526     uint256 hash = tx.GetHash();
527     {
528         LOCK(cs_wallet);
529         bool fExisted = mapWallet.count(hash);
530         if (fExisted && !fUpdate) return false;
531         if (fExisted || IsMine(tx) || IsFromMe(tx))
532         {
533             CWalletTx wtx(this,tx);
534             // Get merkle branch if transaction was found in a block
535             if (pblock)
536                 wtx.SetMerkleBranch(pblock);
537             return AddToWallet(wtx);
538         }
539         else
540             WalletUpdateSpent(tx);
541     }
542     return false;
543 }
544
545 bool CWallet::EraseFromWallet(uint256 hash)
546 {
547     if (!fFileBacked)
548         return false;
549     {
550         LOCK(cs_wallet);
551         if (mapWallet.erase(hash))
552             CWalletDB(strWalletFile).EraseTx(hash);
553     }
554     return true;
555 }
556
557
558 bool CWallet::IsMine(const CTxIn &txin) const
559 {
560     {
561         LOCK(cs_wallet);
562         map<uint256, CWalletTx>::const_iterator mi = mapWallet.find(txin.prevout.hash);
563         if (mi != mapWallet.end())
564         {
565             const CWalletTx& prev = (*mi).second;
566             if (txin.prevout.n < prev.vout.size())
567                 if (IsMine(prev.vout[txin.prevout.n]))
568                     return true;
569         }
570     }
571     return false;
572 }
573
574 int64 CWallet::GetDebit(const CTxIn &txin) const
575 {
576     {
577         LOCK(cs_wallet);
578         map<uint256, CWalletTx>::const_iterator mi = mapWallet.find(txin.prevout.hash);
579         if (mi != mapWallet.end())
580         {
581             const CWalletTx& prev = (*mi).second;
582             if (txin.prevout.n < prev.vout.size())
583                 if (IsMine(prev.vout[txin.prevout.n]))
584                     return prev.vout[txin.prevout.n].nValue;
585         }
586     }
587     return 0;
588 }
589
590 bool CWallet::IsChange(const CTxOut& txout) const
591 {
592     CTxDestination address;
593
594     // TODO: fix handling of 'change' outputs. The assumption is that any
595     // payment to a TX_PUBKEYHASH that is mine but isn't in the address book
596     // is change. That assumption is likely to break when we implement multisignature
597     // wallets that return change back into a multi-signature-protected address;
598     // a better way of identifying which outputs are 'the send' and which are
599     // 'the change' will need to be implemented (maybe extend CWalletTx to remember
600     // which output, if any, was change).
601     if (ExtractDestination(txout.scriptPubKey, address) && ::IsMine(*this, address))
602     {
603         LOCK(cs_wallet);
604         if (!mapAddressBook.count(address))
605             return true;
606     }
607     return false;
608 }
609
610 int64 CWalletTx::GetTxTime() const
611 {
612     int64 n = nTimeSmart;
613     return n ? n : nTimeReceived;
614 }
615
616 int CWalletTx::GetRequestCount() const
617 {
618     // Returns -1 if it wasn't being tracked
619     int nRequests = -1;
620     {
621         LOCK(pwallet->cs_wallet);
622         if (IsCoinBase() || IsCoinStake())
623         {
624             // Generated block
625             if (hashBlock != 0)
626             {
627                 map<uint256, int>::const_iterator mi = pwallet->mapRequestCount.find(hashBlock);
628                 if (mi != pwallet->mapRequestCount.end())
629                     nRequests = (*mi).second;
630             }
631         }
632         else
633         {
634             // Did anyone request this transaction?
635             map<uint256, int>::const_iterator mi = pwallet->mapRequestCount.find(GetHash());
636             if (mi != pwallet->mapRequestCount.end())
637             {
638                 nRequests = (*mi).second;
639
640                 // How about the block it's in?
641                 if (nRequests == 0 && hashBlock != 0)
642                 {
643                     map<uint256, int>::const_iterator mi = pwallet->mapRequestCount.find(hashBlock);
644                     if (mi != pwallet->mapRequestCount.end())
645                         nRequests = (*mi).second;
646                     else
647                         nRequests = 1; // If it's in someone else's block it must have got out
648                 }
649             }
650         }
651     }
652     return nRequests;
653 }
654
655 void CWalletTx::GetAmounts(int64& nGeneratedImmature, int64& nGeneratedMature, list<pair<CTxDestination, int64> >& listReceived,
656                            list<pair<CTxDestination, int64> >& listSent, int64& nFee, string& strSentAccount) const
657 {
658     nGeneratedImmature = nGeneratedMature = nFee = 0;
659     listReceived.clear();
660     listSent.clear();
661     strSentAccount = strFromAccount;
662
663     if (IsCoinBase() || IsCoinStake())
664     {
665         if (GetBlocksToMaturity() > 0)
666             nGeneratedImmature = pwallet->GetCredit(*this);
667         else
668             nGeneratedMature = GetCredit();
669         return;
670     }
671
672     // Compute fee:
673     int64 nDebit = GetDebit();
674     if (nDebit > 0) // debit>0 means we signed/sent this transaction
675     {
676         int64 nValueOut = GetValueOut();
677         nFee = nDebit - nValueOut;
678     }
679
680     // Sent/received.
681     BOOST_FOREACH(const CTxOut& txout, vout)
682     {
683         CTxDestination address;
684         vector<unsigned char> vchPubKey;
685         if (!ExtractDestination(txout.scriptPubKey, address))
686         {
687             printf("CWalletTx::GetAmounts: Unknown transaction type found, txid %s\n",
688                    this->GetHash().ToString().c_str());
689         }
690
691         // Don't report 'change' txouts
692         if (nDebit > 0 && pwallet->IsChange(txout))
693             continue;
694
695         if (nDebit > 0)
696             listSent.push_back(make_pair(address, txout.nValue));
697
698         if (pwallet->IsMine(txout))
699             listReceived.push_back(make_pair(address, txout.nValue));
700     }
701
702 }
703
704 void CWalletTx::GetAccountAmounts(const string& strAccount, int64& nGenerated, int64& nReceived,
705                                   int64& nSent, int64& nFee) const
706 {
707     nGenerated = nReceived = nSent = nFee = 0;
708
709     int64 allGeneratedImmature, allGeneratedMature, allFee;
710     allGeneratedImmature = allGeneratedMature = allFee = 0;
711     string strSentAccount;
712     list<pair<CTxDestination, int64> > listReceived;
713     list<pair<CTxDestination, int64> > listSent;
714     GetAmounts(allGeneratedImmature, allGeneratedMature, listReceived, listSent, allFee, strSentAccount);
715
716     if (strAccount == "")
717         nGenerated = allGeneratedMature;
718     if (strAccount == strSentAccount)
719     {
720         BOOST_FOREACH(const PAIRTYPE(CTxDestination,int64)& s, listSent)
721             nSent += s.second;
722         nFee = allFee;
723     }
724     {
725         LOCK(pwallet->cs_wallet);
726         BOOST_FOREACH(const PAIRTYPE(CTxDestination,int64)& r, listReceived)
727         {
728             if (pwallet->mapAddressBook.count(r.first))
729             {
730                 map<CTxDestination, string>::const_iterator mi = pwallet->mapAddressBook.find(r.first);
731                 if (mi != pwallet->mapAddressBook.end() && (*mi).second == strAccount)
732                     nReceived += r.second;
733             }
734             else if (strAccount.empty())
735             {
736                 nReceived += r.second;
737             }
738         }
739     }
740 }
741
742 void CWalletTx::AddSupportingTransactions(CTxDB& txdb)
743 {
744     vtxPrev.clear();
745
746     const int COPY_DEPTH = 3;
747     if (SetMerkleBranch() < COPY_DEPTH)
748     {
749         vector<uint256> vWorkQueue;
750         BOOST_FOREACH(const CTxIn& txin, vin)
751             vWorkQueue.push_back(txin.prevout.hash);
752
753         // This critsect is OK because txdb is already open
754         {
755             LOCK(pwallet->cs_wallet);
756             map<uint256, const CMerkleTx*> mapWalletPrev;
757             set<uint256> setAlreadyDone;
758             for (unsigned int i = 0; i < vWorkQueue.size(); i++)
759             {
760                 uint256 hash = vWorkQueue[i];
761                 if (setAlreadyDone.count(hash))
762                     continue;
763                 setAlreadyDone.insert(hash);
764
765                 CMerkleTx tx;
766                 map<uint256, CWalletTx>::const_iterator mi = pwallet->mapWallet.find(hash);
767                 if (mi != pwallet->mapWallet.end())
768                 {
769                     tx = (*mi).second;
770                     BOOST_FOREACH(const CMerkleTx& txWalletPrev, (*mi).second.vtxPrev)
771                         mapWalletPrev[txWalletPrev.GetHash()] = &txWalletPrev;
772                 }
773                 else if (mapWalletPrev.count(hash))
774                 {
775                     tx = *mapWalletPrev[hash];
776                 }
777                 else if (!fClient && txdb.ReadDiskTx(hash, tx))
778                 {
779                     ;
780                 }
781                 else
782                 {
783                     printf("ERROR: AddSupportingTransactions() : unsupported transaction\n");
784                     continue;
785                 }
786
787                 int nDepth = tx.SetMerkleBranch();
788                 vtxPrev.push_back(tx);
789
790                 if (nDepth < COPY_DEPTH)
791                 {
792                     BOOST_FOREACH(const CTxIn& txin, tx.vin)
793                         vWorkQueue.push_back(txin.prevout.hash);
794                 }
795             }
796         }
797     }
798
799     reverse(vtxPrev.begin(), vtxPrev.end());
800 }
801
802 bool CWalletTx::WriteToDisk()
803 {
804     return CWalletDB(pwallet->strWalletFile).WriteTx(GetHash(), *this);
805 }
806
807 // Scan the block chain (starting in pindexStart) for transactions
808 // from or to us. If fUpdate is true, found transactions that already
809 // exist in the wallet will be updated.
810 int CWallet::ScanForWalletTransactions(CBlockIndex* pindexStart, bool fUpdate)
811 {
812     int ret = 0;
813
814     CBlockIndex* pindex = pindexStart;
815     {
816         LOCK(cs_wallet);
817         while (pindex)
818         {
819             CBlock block;
820             block.ReadFromDisk(pindex, true);
821             BOOST_FOREACH(CTransaction& tx, block.vtx)
822             {
823                 if (AddToWalletIfInvolvingMe(tx, &block, fUpdate))
824                     ret++;
825             }
826             pindex = pindex->pnext;
827         }
828     }
829     return ret;
830 }
831
832 int CWallet::ScanForWalletTransaction(const uint256& hashTx)
833 {
834     CTransaction tx;
835     tx.ReadFromDisk(COutPoint(hashTx, 0));
836     if (AddToWalletIfInvolvingMe(tx, NULL, true, true))
837         return 1;
838     return 0;
839 }
840
841 void CWallet::ReacceptWalletTransactions()
842 {
843     CTxDB txdb("r");
844     bool fRepeat = true;
845     while (fRepeat)
846     {
847         LOCK(cs_wallet);
848         fRepeat = false;
849         vector<CDiskTxPos> vMissingTx;
850         BOOST_FOREACH(PAIRTYPE(const uint256, CWalletTx)& item, mapWallet)
851         {
852             CWalletTx& wtx = item.second;
853             if ((wtx.IsCoinBase() && wtx.IsSpent(0)) || (wtx.IsCoinStake() && wtx.IsSpent(1)))
854                 continue;
855
856             CTxIndex txindex;
857             bool fUpdated = false;
858             if (txdb.ReadTxIndex(wtx.GetHash(), txindex))
859             {
860                 // Update fSpent if a tx got spent somewhere else by a copy of wallet.dat
861                 if (txindex.vSpent.size() != wtx.vout.size())
862                 {
863                     printf("ERROR: ReacceptWalletTransactions() : txindex.vSpent.size() %"PRIszu" != wtx.vout.size() %"PRIszu"\n", txindex.vSpent.size(), wtx.vout.size());
864                     continue;
865                 }
866                 for (unsigned int i = 0; i < txindex.vSpent.size(); i++)
867                 {
868                     if (wtx.IsSpent(i))
869                         continue;
870                     if (!txindex.vSpent[i].IsNull() && IsMine(wtx.vout[i]))
871                     {
872                         wtx.MarkSpent(i);
873                         fUpdated = true;
874                         vMissingTx.push_back(txindex.vSpent[i]);
875                     }
876                 }
877                 if (fUpdated)
878                 {
879                     printf("ReacceptWalletTransactions found spent coin %snvc %s\n", FormatMoney(wtx.GetCredit()).c_str(), wtx.GetHash().ToString().c_str());
880                     wtx.MarkDirty();
881                     wtx.WriteToDisk();
882                 }
883             }
884             else
885             {
886                 // Re-accept any txes of ours that aren't already in a block
887                 if (!(wtx.IsCoinBase() || wtx.IsCoinStake()))
888                     wtx.AcceptWalletTransaction(txdb, false);
889             }
890         }
891         if (!vMissingTx.empty())
892         {
893             // TODO: optimize this to scan just part of the block chain?
894             if (ScanForWalletTransactions(pindexGenesisBlock))
895                 fRepeat = true;  // Found missing transactions: re-do re-accept.
896         }
897     }
898 }
899
900 void CWalletTx::RelayWalletTransaction(CTxDB& txdb)
901 {
902     BOOST_FOREACH(const CMerkleTx& tx, vtxPrev)
903     {
904         if (!(tx.IsCoinBase() || tx.IsCoinStake()))
905         {
906             uint256 hash = tx.GetHash();
907             if (!txdb.ContainsTx(hash))
908                 RelayTransaction((CTransaction)tx, hash);
909         }
910     }
911     if (!(IsCoinBase() || IsCoinStake()))
912     {
913         uint256 hash = GetHash();
914         if (!txdb.ContainsTx(hash))
915         {
916             printf("Relaying wtx %s\n", hash.ToString().substr(0,10).c_str());
917             RelayTransaction((CTransaction)*this, hash);
918         }
919     }
920 }
921
922 void CWalletTx::RelayWalletTransaction()
923 {
924    CTxDB txdb("r");
925    RelayWalletTransaction(txdb);
926 }
927
928 void CWallet::ResendWalletTransactions()
929 {
930     // Do this infrequently and randomly to avoid giving away
931     // that these are our transactions.
932     static int64 nNextTime;
933     if (GetTime() < nNextTime)
934         return;
935     bool fFirst = (nNextTime == 0);
936     nNextTime = GetTime() + GetRand(30 * 60);
937     if (fFirst)
938         return;
939
940     // Only do it if there's been a new block since last time
941     static int64 nLastTime;
942     if (nTimeBestReceived < nLastTime)
943         return;
944     nLastTime = GetTime();
945
946     // Rebroadcast any of our txes that aren't in a block yet
947     printf("ResendWalletTransactions()\n");
948     CTxDB txdb("r");
949     {
950         LOCK(cs_wallet);
951         // Sort them in chronological order
952         multimap<unsigned int, CWalletTx*> mapSorted;
953         BOOST_FOREACH(PAIRTYPE(const uint256, CWalletTx)& item, mapWallet)
954         {
955             CWalletTx& wtx = item.second;
956             // Don't rebroadcast until it's had plenty of time that
957             // it should have gotten in already by now.
958             if (nTimeBestReceived - (int64)wtx.nTimeReceived > 5 * 60)
959                 mapSorted.insert(make_pair(wtx.nTimeReceived, &wtx));
960         }
961         BOOST_FOREACH(PAIRTYPE(const unsigned int, CWalletTx*)& item, mapSorted)
962         {
963             CWalletTx& wtx = *item.second;
964             if (wtx.CheckTransaction())
965                 wtx.RelayWalletTransaction(txdb);
966             else
967                 printf("ResendWalletTransactions() : CheckTransaction failed for transaction %s\n", wtx.GetHash().ToString().c_str());
968         }
969     }
970 }
971
972
973
974
975
976
977 //////////////////////////////////////////////////////////////////////////////
978 //
979 // Actions
980 //
981
982
983 int64 CWallet::GetBalance() const
984 {
985     int64 nTotal = 0;
986     {
987         LOCK(cs_wallet);
988         for (map<uint256, CWalletTx>::const_iterator it = mapWallet.begin(); it != mapWallet.end(); ++it)
989         {
990             const CWalletTx* pcoin = &(*it).second;
991             if (pcoin->IsConfirmed())
992                 nTotal += pcoin->GetAvailableCredit();
993         }
994     }
995
996     return nTotal;
997 }
998
999 int64 CWallet::GetUnconfirmedBalance() const
1000 {
1001     int64 nTotal = 0;
1002     {
1003         LOCK(cs_wallet);
1004         for (map<uint256, CWalletTx>::const_iterator it = mapWallet.begin(); it != mapWallet.end(); ++it)
1005         {
1006             const CWalletTx* pcoin = &(*it).second;
1007             if (!pcoin->IsFinal() || !pcoin->IsConfirmed())
1008                 nTotal += pcoin->GetAvailableCredit();
1009         }
1010     }
1011     return nTotal;
1012 }
1013
1014 int64 CWallet::GetImmatureBalance() const
1015 {
1016     int64 nTotal = 0;
1017     {
1018         LOCK(cs_wallet);
1019         for (map<uint256, CWalletTx>::const_iterator it = mapWallet.begin(); it != mapWallet.end(); ++it)
1020         {
1021             const CWalletTx& pcoin = (*it).second;
1022             if (pcoin.IsCoinBase() && pcoin.GetBlocksToMaturity() > 0 && pcoin.IsInMainChain())
1023                 nTotal += GetCredit(pcoin);
1024         }
1025     }
1026     return nTotal;
1027 }
1028
1029 // populate vCoins with vector of spendable COutputs
1030 void CWallet::AvailableCoins(vector<COutput>& vCoins, bool fOnlyConfirmed, const CCoinControl *coinControl) const
1031 {
1032     vCoins.clear();
1033
1034     {
1035         LOCK(cs_wallet);
1036         for (map<uint256, CWalletTx>::const_iterator it = mapWallet.begin(); it != mapWallet.end(); ++it)
1037         {
1038             const CWalletTx* pcoin = &(*it).second;
1039
1040             if (!pcoin->IsFinal())
1041                 continue;
1042
1043             if (fOnlyConfirmed && !pcoin->IsConfirmed())
1044                 continue;
1045
1046             if (pcoin->IsCoinBase() && pcoin->GetBlocksToMaturity() > 0)
1047                 continue;
1048
1049             if(pcoin->IsCoinStake() && pcoin->GetBlocksToMaturity() > 0)
1050                 continue;
1051
1052             for (unsigned int i = 0; i < pcoin->vout.size(); i++)
1053                 if (!(pcoin->IsSpent(i)) && IsMine(pcoin->vout[i]) && pcoin->vout[i].nValue >= nMinimumInputValue &&
1054                 (!coinControl || !coinControl->HasSelected() || coinControl->IsSelected((*it).first, i)))
1055                     vCoins.push_back(COutput(pcoin, i, pcoin->GetDepthInMainChain()));
1056
1057         }
1058     }
1059 }
1060
1061 void CWallet::AvailableCoinsMinConf(vector<COutput>& vCoins, int nConf) const
1062 {
1063     vCoins.clear();
1064
1065     {
1066         LOCK(cs_wallet);
1067         for (map<uint256, CWalletTx>::const_iterator it = mapWallet.begin(); it != mapWallet.end(); ++it)
1068         {
1069             const CWalletTx* pcoin = &(*it).second;
1070
1071             if (!pcoin->IsFinal())
1072                 continue;
1073
1074             if(pcoin->GetDepthInMainChain() < nConf)
1075                 continue;
1076
1077             for (unsigned int i = 0; i < pcoin->vout.size(); i++)
1078                 if (!(pcoin->IsSpent(i)) && IsMine(pcoin->vout[i]) && pcoin->vout[i].nValue >= nMinimumInputValue)
1079                     vCoins.push_back(COutput(pcoin, i, pcoin->GetDepthInMainChain()));
1080         }
1081     }
1082 }
1083
1084 static void ApproximateBestSubset(vector<pair<int64, pair<const CWalletTx*,unsigned int> > >vValue, int64 nTotalLower, int64 nTargetValue,
1085                                   vector<char>& vfBest, int64& nBest, int iterations = 1000)
1086 {
1087     vector<char> vfIncluded;
1088
1089     vfBest.assign(vValue.size(), true);
1090     nBest = nTotalLower;
1091
1092     for (int nRep = 0; nRep < iterations && nBest != nTargetValue; nRep++)
1093     {
1094         vfIncluded.assign(vValue.size(), false);
1095         int64 nTotal = 0;
1096         bool fReachedTarget = false;
1097         for (int nPass = 0; nPass < 2 && !fReachedTarget; nPass++)
1098         {
1099             for (unsigned int i = 0; i < vValue.size(); i++)
1100             {
1101                 if (nPass == 0 ? rand() % 2 : !vfIncluded[i])
1102                 {
1103                     nTotal += vValue[i].first;
1104                     vfIncluded[i] = true;
1105                     if (nTotal >= nTargetValue)
1106                     {
1107                         fReachedTarget = true;
1108                         if (nTotal < nBest)
1109                         {
1110                             nBest = nTotal;
1111                             vfBest = vfIncluded;
1112                         }
1113                         nTotal -= vValue[i].first;
1114                         vfIncluded[i] = false;
1115                     }
1116                 }
1117             }
1118         }
1119     }
1120 }
1121
1122 // ppcoin: total coins staked (non-spendable until maturity)
1123 int64 CWallet::GetStake() const
1124 {
1125     int64 nTotal = 0;
1126     LOCK(cs_wallet);
1127     for (map<uint256, CWalletTx>::const_iterator it = mapWallet.begin(); it != mapWallet.end(); ++it)
1128     {
1129         const CWalletTx* pcoin = &(*it).second;
1130         if (pcoin->IsCoinStake() && pcoin->GetBlocksToMaturity() > 0 && pcoin->GetDepthInMainChain() > 0)
1131             nTotal += CWallet::GetCredit(*pcoin);
1132     }
1133     return nTotal;
1134 }
1135
1136 int64 CWallet::GetNewMint() const
1137 {
1138     int64 nTotal = 0;
1139     LOCK(cs_wallet);
1140     for (map<uint256, CWalletTx>::const_iterator it = mapWallet.begin(); it != mapWallet.end(); ++it)
1141     {
1142         const CWalletTx* pcoin = &(*it).second;
1143         if (pcoin->IsCoinBase() && pcoin->GetBlocksToMaturity() > 0 && pcoin->GetDepthInMainChain() > 0)
1144             nTotal += CWallet::GetCredit(*pcoin);
1145     }
1146     return nTotal;
1147 }
1148
1149 bool CWallet::SelectCoinsMinConf(int64 nTargetValue, unsigned int nSpendTime, int nConfMine, int nConfTheirs, vector<COutput> vCoins, set<pair<const CWalletTx*,unsigned int> >& setCoinsRet, int64& nValueRet) const
1150 {
1151     setCoinsRet.clear();
1152     nValueRet = 0;
1153
1154     // List of values less than target
1155     pair<int64, pair<const CWalletTx*,unsigned int> > coinLowestLarger;
1156     coinLowestLarger.first = std::numeric_limits<int64>::max();
1157     coinLowestLarger.second.first = NULL;
1158     vector<pair<int64, pair<const CWalletTx*,unsigned int> > > vValue;
1159     int64 nTotalLower = 0;
1160
1161     random_shuffle(vCoins.begin(), vCoins.end(), GetRandInt);
1162
1163     BOOST_FOREACH(COutput output, vCoins)
1164     {
1165         const CWalletTx *pcoin = output.tx;
1166
1167         if (output.nDepth < (pcoin->IsFromMe() ? nConfMine : nConfTheirs))
1168             continue;
1169
1170         int i = output.i;
1171
1172         // Follow the timestamp rules
1173         if (pcoin->nTime > nSpendTime)
1174             continue;
1175
1176         int64 n = pcoin->vout[i].nValue;
1177
1178         pair<int64,pair<const CWalletTx*,unsigned int> > coin = make_pair(n,make_pair(pcoin, i));
1179
1180         if (n == nTargetValue)
1181         {
1182             setCoinsRet.insert(coin.second);
1183             nValueRet += coin.first;
1184             return true;
1185         }
1186         else if (n < nTargetValue + CENT)
1187         {
1188             vValue.push_back(coin);
1189             nTotalLower += n;
1190         }
1191         else if (n < coinLowestLarger.first)
1192         {
1193             coinLowestLarger = coin;
1194         }
1195     }
1196
1197     if (nTotalLower == nTargetValue)
1198     {
1199         for (unsigned int i = 0; i < vValue.size(); ++i)
1200         {
1201             setCoinsRet.insert(vValue[i].second);
1202             nValueRet += vValue[i].first;
1203         }
1204         return true;
1205     }
1206
1207     if (nTotalLower < nTargetValue)
1208     {
1209         if (coinLowestLarger.second.first == NULL)
1210             return false;
1211         setCoinsRet.insert(coinLowestLarger.second);
1212         nValueRet += coinLowestLarger.first;
1213         return true;
1214     }
1215
1216     // Solve subset sum by stochastic approximation
1217     sort(vValue.rbegin(), vValue.rend(), CompareValueOnly());
1218     vector<char> vfBest;
1219     int64 nBest;
1220
1221     ApproximateBestSubset(vValue, nTotalLower, nTargetValue, vfBest, nBest, 1000);
1222     if (nBest != nTargetValue && nTotalLower >= nTargetValue + CENT)
1223         ApproximateBestSubset(vValue, nTotalLower, nTargetValue + CENT, vfBest, nBest, 1000);
1224
1225     // If we have a bigger coin and (either the stochastic approximation didn't find a good solution,
1226     //                                   or the next bigger coin is closer), return the bigger coin
1227     if (coinLowestLarger.second.first &&
1228         ((nBest != nTargetValue && nBest < nTargetValue + CENT) || coinLowestLarger.first <= nBest))
1229     {
1230         setCoinsRet.insert(coinLowestLarger.second);
1231         nValueRet += coinLowestLarger.first;
1232     }
1233     else {
1234         for (unsigned int i = 0; i < vValue.size(); i++)
1235             if (vfBest[i])
1236             {
1237                 setCoinsRet.insert(vValue[i].second);
1238                 nValueRet += vValue[i].first;
1239             }
1240
1241         if (fDebug && GetBoolArg("-printpriority"))
1242         {
1243             //// debug print
1244             printf("SelectCoins() best subset: ");
1245             for (unsigned int i = 0; i < vValue.size(); i++)
1246                 if (vfBest[i])
1247                     printf("%s ", FormatMoney(vValue[i].first).c_str());
1248             printf("total %s\n", FormatMoney(nBest).c_str());
1249         }
1250     }
1251
1252     return true;
1253 }
1254
1255 bool CWallet::SelectCoins(int64 nTargetValue, unsigned int nSpendTime, set<pair<const CWalletTx*,unsigned int> >& setCoinsRet, int64& nValueRet, const CCoinControl* coinControl) const
1256 {
1257     vector<COutput> vCoins;
1258     AvailableCoins(vCoins, true, coinControl);
1259
1260     // coin control -> return all selected outputs (we want all selected to go into the transaction for sure)
1261     if (coinControl && coinControl->HasSelected())
1262     {
1263         BOOST_FOREACH(const COutput& out, vCoins)
1264         {
1265             nValueRet += out.tx->vout[out.i].nValue;
1266             setCoinsRet.insert(make_pair(out.tx, out.i));
1267         }
1268         return (nValueRet >= nTargetValue);
1269     }
1270
1271     return (SelectCoinsMinConf(nTargetValue, nSpendTime, 1, 6, vCoins, setCoinsRet, nValueRet) ||
1272             SelectCoinsMinConf(nTargetValue, nSpendTime, 1, 1, vCoins, setCoinsRet, nValueRet) ||
1273             SelectCoinsMinConf(nTargetValue, nSpendTime, 0, 1, vCoins, setCoinsRet, nValueRet));
1274 }
1275
1276 // Select some coins without random shuffle or best subset approximation
1277 bool CWallet::SelectCoinsSimple(int64 nTargetValue, unsigned int nSpendTime, int nMinConf, set<pair<const CWalletTx*,unsigned int> >& setCoinsRet, int64& nValueRet) const
1278 {
1279     vector<COutput> vCoins;
1280     AvailableCoinsMinConf(vCoins, nMinConf);
1281
1282     setCoinsRet.clear();
1283     nValueRet = 0;
1284
1285     BOOST_FOREACH(COutput output, vCoins)
1286     {
1287         const CWalletTx *pcoin = output.tx;
1288         int i = output.i;
1289
1290         // Stop if we've chosen enough inputs
1291         if (nValueRet >= nTargetValue)
1292             break;
1293
1294         // Follow the timestamp rules
1295         if (pcoin->nTime > nSpendTime)
1296             continue;
1297
1298         int64 n = pcoin->vout[i].nValue;
1299
1300         pair<int64,pair<const CWalletTx*,unsigned int> > coin = make_pair(n,make_pair(pcoin, i));
1301
1302         if (n >= nTargetValue)
1303         {
1304             // If input value is greater or equal to target then simply insert
1305             //    it into the current subset and exit
1306             setCoinsRet.insert(coin.second);
1307             nValueRet += coin.first;
1308             break;
1309         }
1310         else if (n < nTargetValue + CENT)
1311         {
1312             setCoinsRet.insert(coin.second);
1313             nValueRet += coin.first;
1314         }
1315     }
1316
1317     return true;
1318 }
1319
1320 bool CWallet::CreateTransaction(const vector<pair<CScript, int64> >& vecSend, CWalletTx& wtxNew, CReserveKey& reservekey, int64& nFeeRet, const CCoinControl* coinControl)
1321 {
1322     int64 nValue = 0;
1323     BOOST_FOREACH (const PAIRTYPE(CScript, int64)& s, vecSend)
1324     {
1325         if (nValue < 0)
1326             return false;
1327         nValue += s.second;
1328     }
1329     if (vecSend.empty() || nValue < 0)
1330         return false;
1331
1332     wtxNew.BindWallet(this);
1333
1334     {
1335         LOCK2(cs_main, cs_wallet);
1336         // txdb must be opened before the mapWallet lock
1337         CTxDB txdb("r");
1338         {
1339             nFeeRet = nTransactionFee;
1340             while (true)
1341             {
1342                 wtxNew.vin.clear();
1343                 wtxNew.vout.clear();
1344                 wtxNew.fFromMe = true;
1345
1346                 int64 nTotalValue = nValue + nFeeRet;
1347                 double dPriority = 0;
1348                 // vouts to the payees
1349                 BOOST_FOREACH (const PAIRTYPE(CScript, int64)& s, vecSend)
1350                     wtxNew.vout.push_back(CTxOut(s.second, s.first));
1351
1352                 // Choose coins to use
1353                 set<pair<const CWalletTx*,unsigned int> > setCoins;
1354                 int64 nValueIn = 0;
1355                 if (!SelectCoins(nTotalValue, wtxNew.nTime, setCoins, nValueIn, coinControl))
1356                     return false;
1357                 BOOST_FOREACH(PAIRTYPE(const CWalletTx*, unsigned int) pcoin, setCoins)
1358                 {
1359                     int64 nCredit = pcoin.first->vout[pcoin.second].nValue;
1360                     dPriority += (double)nCredit * pcoin.first->GetDepthInMainChain();
1361                 }
1362
1363                 int64 nChange = nValueIn - nValue - nFeeRet;
1364                 // if sub-cent change is required, the fee must be raised to at least MIN_TX_FEE
1365                 // or until nChange becomes zero
1366                 // NOTE: this depends on the exact behaviour of GetMinFee
1367                 if (nFeeRet < MIN_TX_FEE && nChange > 0 && nChange < CENT)
1368                 {
1369                     int64 nMoveToFee = min(nChange, MIN_TX_FEE - nFeeRet);
1370                     nChange -= nMoveToFee;
1371                     nFeeRet += nMoveToFee;
1372                 }
1373
1374                 // ppcoin: sub-cent change is moved to fee
1375                 if (nChange > 0 && nChange < MIN_TXOUT_AMOUNT)
1376                 {
1377                     nFeeRet += nChange;
1378                     nChange = 0;
1379                 }
1380
1381                 if (nChange > 0)
1382                 {
1383                     // Fill a vout to ourself
1384                     // TODO: pass in scriptChange instead of reservekey so
1385                     // change transaction isn't always pay-to-bitcoin-address
1386                     CScript scriptChange;
1387
1388                     // coin control: send change to custom address
1389                     if (coinControl && !boost::get<CNoDestination>(&coinControl->destChange))
1390                         scriptChange.SetDestination(coinControl->destChange);
1391
1392                     // no coin control: send change to newly generated address
1393                     else
1394                     {
1395                         // Note: We use a new key here to keep it from being obvious which side is the change.
1396                         //  The drawback is that by not reusing a previous key, the change may be lost if a
1397                         //  backup is restored, if the backup doesn't have the new private key for the change.
1398                         //  If we reused the old key, it would be possible to add code to look for and
1399                         //  rediscover unknown transactions that were written with keys of ours to recover
1400                         //  post-backup change.
1401
1402                         // Reserve a new key pair from key pool
1403                         CPubKey vchPubKey = reservekey.GetReservedKey();
1404
1405                         scriptChange.SetDestination(vchPubKey.GetID());
1406                     }
1407
1408                     // Insert change txn at random position:
1409                     vector<CTxOut>::iterator position = wtxNew.vout.begin()+GetRandInt(wtxNew.vout.size());
1410                     wtxNew.vout.insert(position, CTxOut(nChange, scriptChange));
1411                 }
1412                 else
1413                     reservekey.ReturnKey();
1414
1415                 // Fill vin
1416                 BOOST_FOREACH(const PAIRTYPE(const CWalletTx*,unsigned int)& coin, setCoins)
1417                     wtxNew.vin.push_back(CTxIn(coin.first->GetHash(),coin.second));
1418
1419                 // Sign
1420                 int nIn = 0;
1421                 BOOST_FOREACH(const PAIRTYPE(const CWalletTx*,unsigned int)& coin, setCoins)
1422                     if (!SignSignature(*this, *coin.first, wtxNew, nIn++))
1423                         return false;
1424
1425                 // Limit size
1426                 unsigned int nBytes = ::GetSerializeSize(*(CTransaction*)&wtxNew, SER_NETWORK, PROTOCOL_VERSION);
1427                 if (nBytes >= MAX_BLOCK_SIZE_GEN/5)
1428                     return false;
1429                 dPriority /= nBytes;
1430
1431                 // Check that enough fee is included
1432                 int64 nPayFee = nTransactionFee * (1 + (int64)nBytes / 1000);
1433                 int64 nMinFee = wtxNew.GetMinFee(1, false, GMF_SEND, nBytes);
1434
1435                 if (nFeeRet < max(nPayFee, nMinFee))
1436                 {
1437                     nFeeRet = max(nPayFee, nMinFee);
1438                     continue;
1439                 }
1440
1441                 // Fill vtxPrev by copying from previous transactions vtxPrev
1442                 wtxNew.AddSupportingTransactions(txdb);
1443                 wtxNew.fTimeReceivedIsTxTime = true;
1444
1445                 break;
1446             }
1447         }
1448     }
1449     return true;
1450 }
1451
1452 bool CWallet::CreateTransaction(CScript scriptPubKey, int64 nValue, CWalletTx& wtxNew, CReserveKey& reservekey, int64& nFeeRet, const CCoinControl* coinControl)
1453 {
1454     vector< pair<CScript, int64> > vecSend;
1455     vecSend.push_back(make_pair(scriptPubKey, nValue));
1456     return CreateTransaction(vecSend, wtxNew, reservekey, nFeeRet, coinControl);
1457 }
1458
1459 // NovaCoin: get current stake weight
1460 bool CWallet::GetStakeWeight(const CKeyStore& keystore, uint64& nMinWeight, uint64& nMaxWeight, uint64& nWeight)
1461 {
1462     // Choose coins to use
1463     int64 nBalance = GetBalance();
1464     int64 nReserveBalance = 0;
1465
1466     if (mapArgs.count("-reservebalance") && !ParseMoney(mapArgs["-reservebalance"], nReserveBalance))
1467     {
1468         error("GetStakeWeight : invalid reserve balance amount");
1469         return false;
1470     }
1471
1472     if (nBalance <= nReserveBalance)
1473         return false;
1474
1475     vector<const CWalletTx*> vwtxPrev;
1476
1477 /*
1478  * TODO: performance comparison
1479
1480     static set<pair<const CWalletTx*,unsigned int> > setCoins;
1481     static uint256 hashPrevBlock;
1482     static int64 nValueIn = 0;
1483
1484     // Cache outputs unless best block changed
1485     if (hashPrevBlock != pindexBest->GetBlockHash())
1486     {
1487         if (!SelectCoinsSimple(nBalance - nReserveBalance, GetAdjustedTime(), nCoinbaseMaturity * 10, setCoins, nValueIn))
1488             return false;
1489
1490         if (setCoins.empty())
1491             return false;
1492
1493         hashPrevBlock == pindexBest->GetBlockHash();
1494     }
1495 */
1496
1497     set<pair<const CWalletTx*,unsigned int> > setCoins;
1498     int64 nValueIn = 0;
1499
1500     if (!SelectCoinsSimple(nBalance - nReserveBalance, GetTime(), nCoinbaseMaturity * 10, setCoins, nValueIn))
1501         return false;
1502
1503     if (setCoins.empty())
1504         return false;
1505
1506     CTxDB txdb("r");
1507     BOOST_FOREACH(PAIRTYPE(const CWalletTx*, unsigned int) pcoin, setCoins)
1508     {
1509         CTxIndex txindex;
1510         {
1511             LOCK2(cs_main, cs_wallet);
1512             if (!txdb.ReadTxIndex(pcoin.first->GetHash(), txindex))
1513                 continue;
1514         }
1515
1516         int64 nTimeWeight = GetWeight((int64)pcoin.first->nTime, (int64)GetTime());
1517         CBigNum bnCoinDayWeight = CBigNum(pcoin.first->vout[pcoin.second].nValue) * nTimeWeight / COIN / (24 * 60 * 60);
1518
1519         // Weight is greater than zero
1520         if (nTimeWeight > 0)
1521         {
1522             nWeight += bnCoinDayWeight.getuint64();
1523         }
1524
1525         // Weight is greater than zero, but the maximum value isn't reached yet
1526         if (nTimeWeight > 0 && nTimeWeight < nStakeMaxAge)
1527         {
1528             nMinWeight += bnCoinDayWeight.getuint64();
1529         }
1530
1531         // Maximum weight was reached
1532         if (nTimeWeight == nStakeMaxAge)
1533         {
1534             nMaxWeight += bnCoinDayWeight.getuint64();
1535         }
1536     }
1537
1538     return true;
1539 }
1540
1541 bool CWallet::CreateCoinStake(const CKeyStore& keystore, unsigned int nBits, int64 nSearchInterval, CTransaction& txNew, CKey& key)
1542 {
1543     // The following combine threshold is important to security
1544     // Should not be adjusted if you don't understand the consequences
1545     int64 nCombineThreshold = GetProofOfWorkReward(GetLastBlockIndex(pindexBest, false)->nBits) / 3;
1546
1547     CBigNum bnTargetPerCoinDay;
1548     bnTargetPerCoinDay.SetCompact(nBits);
1549
1550     txNew.vin.clear();
1551     txNew.vout.clear();
1552
1553     // Mark coin stake transaction
1554     CScript scriptEmpty;
1555     scriptEmpty.clear();
1556     txNew.vout.push_back(CTxOut(0, scriptEmpty));
1557
1558     // Choose coins to use
1559     int64 nBalance = GetBalance();
1560     int64 nReserveBalance = 0;
1561
1562     if (mapArgs.count("-reservebalance") && !ParseMoney(mapArgs["-reservebalance"], nReserveBalance))
1563         return error("CreateCoinStake : invalid reserve balance amount");
1564
1565     if (nBalance <= nReserveBalance)
1566         return false;
1567
1568     vector<const CWalletTx*> vwtxPrev;
1569
1570 /*
1571  * TODO: performance comparison
1572
1573     static set<pair<const CWalletTx*,unsigned int> > setCoins;
1574     static uint256 hashPrevBlock;
1575     static int64 nValueIn = 0;
1576
1577     // Cache outputs unless best block changed
1578     if (hashPrevBlock != pindexBest->GetBlockHash())
1579     {
1580         if (!SelectCoinsSimple(nBalance - nReserveBalance, txNew.nTime, nCoinbaseMaturity * 10, setCoins, nValueIn))
1581             return false;
1582
1583         if (setCoins.empty())
1584             return false;
1585
1586         hashPrevBlock == pindexBest->GetBlockHash();
1587     }
1588 */
1589
1590     set<pair<const CWalletTx*,unsigned int> > setCoins;
1591     int64 nValueIn = 0;
1592
1593     // Select coins with suitable depth
1594     if (!SelectCoinsSimple(nBalance - nReserveBalance, txNew.nTime, nCoinbaseMaturity * 10, setCoins, nValueIn))
1595         return false;
1596
1597     if (setCoins.empty())
1598         return false;
1599
1600     int64 nCredit = 0;
1601     CScript scriptPubKeyKernel;
1602     CTxDB txdb("r");
1603     BOOST_FOREACH(PAIRTYPE(const CWalletTx*, unsigned int) pcoin, setCoins)
1604     {
1605         CTxIndex txindex;
1606         {
1607             LOCK2(cs_main, cs_wallet);
1608             if (!txdb.ReadTxIndex(pcoin.first->GetHash(), txindex))
1609                 continue;
1610         }
1611
1612         // Read block header
1613         CBlock block;
1614         {
1615             LOCK2(cs_main, cs_wallet);
1616             if (!block.ReadFromDisk(txindex.pos.nFile, txindex.pos.nBlockPos, false))
1617                 continue;
1618         }
1619
1620         static int nMaxStakeSearchInterval = 60;
1621         if (block.GetBlockTime() + nStakeMinAge > txNew.nTime - nMaxStakeSearchInterval)
1622             continue; // only count coins meeting min age requirement
1623
1624         bool fKernelFound = false;
1625         for (unsigned int n=0; n<min(nSearchInterval,(int64)nMaxStakeSearchInterval) && !fKernelFound && !fShutdown; n++)
1626         {
1627             // Search backward in time from the given txNew timestamp 
1628             // Search nSearchInterval seconds back up to nMaxStakeSearchInterval
1629             uint256 hashProofOfStake = 0, targetProofOfStake = 0;
1630             COutPoint prevoutStake = COutPoint(pcoin.first->GetHash(), pcoin.second);
1631             if (CheckStakeKernelHash(nBits, block, txindex.pos.nTxPos - txindex.pos.nBlockPos, *pcoin.first, prevoutStake, txNew.nTime - n, hashProofOfStake, targetProofOfStake))
1632             {
1633                 // Found a kernel
1634                 if (fDebug && GetBoolArg("-printcoinstake"))
1635                     printf("CreateCoinStake : kernel found\n");
1636                 vector<valtype> vSolutions;
1637                 txnouttype whichType;
1638                 CScript scriptPubKeyOut;
1639                 scriptPubKeyKernel = pcoin.first->vout[pcoin.second].scriptPubKey;
1640                 if (!Solver(scriptPubKeyKernel, whichType, vSolutions))
1641                 {
1642                     if (fDebug && GetBoolArg("-printcoinstake"))
1643                         printf("CreateCoinStake : failed to parse kernel\n");
1644                     break;
1645                 }
1646                 if (fDebug && GetBoolArg("-printcoinstake"))
1647                     printf("CreateCoinStake : parsed kernel type=%d\n", whichType);
1648                 if (whichType != TX_PUBKEY && whichType != TX_PUBKEYHASH)
1649                 {
1650                     if (fDebug && GetBoolArg("-printcoinstake"))
1651                         printf("CreateCoinStake : no support for kernel type=%d\n", whichType);
1652                     break;  // only support pay to public key and pay to address
1653                 }
1654                 if (whichType == TX_PUBKEYHASH) // pay to address type
1655                 {
1656                     // convert to pay to public key type
1657                     if (!keystore.GetKey(uint160(vSolutions[0]), key))
1658                     {
1659                         if (fDebug && GetBoolArg("-printcoinstake"))
1660                             printf("CreateCoinStake : failed to get key for kernel type=%d\n", whichType);
1661                         break;  // unable to find corresponding public key
1662                     }
1663                     scriptPubKeyOut << key.GetPubKey() << OP_CHECKSIG;
1664                 }
1665                 if (whichType == TX_PUBKEY)
1666                 {
1667                     valtype& vchPubKey = vSolutions[0];
1668                     if (!keystore.GetKey(Hash160(vchPubKey), key))
1669                     {
1670                         if (fDebug && GetBoolArg("-printcoinstake"))
1671                             printf("CreateCoinStake : failed to get key for kernel type=%d\n", whichType);
1672                         break;  // unable to find corresponding public key
1673                     }
1674
1675                 if (key.GetPubKey() != vchPubKey)
1676                 {
1677                     if (fDebug && GetBoolArg("-printcoinstake"))
1678                         printf("CreateCoinStake : invalid key for kernel type=%d\n", whichType);
1679                         break; // keys mismatch
1680                     }
1681
1682                     scriptPubKeyOut = scriptPubKeyKernel;
1683                 }
1684
1685                 txNew.nTime -= n;
1686                 txNew.vin.push_back(CTxIn(pcoin.first->GetHash(), pcoin.second));
1687                 nCredit += pcoin.first->vout[pcoin.second].nValue;
1688                 vwtxPrev.push_back(pcoin.first);
1689                 txNew.vout.push_back(CTxOut(0, scriptPubKeyOut));
1690
1691                 if (GetWeight(block.GetBlockTime(), (int64)txNew.nTime) < nStakeMaxAge)
1692                     txNew.vout.push_back(CTxOut(0, scriptPubKeyOut)); //split stake
1693                 if (fDebug && GetBoolArg("-printcoinstake"))
1694                     printf("CreateCoinStake : added kernel type=%d\n", whichType);
1695                 fKernelFound = true;
1696                 break;
1697             }
1698         }
1699
1700         if (fKernelFound || fShutdown)
1701             break; // if kernel is found stop searching
1702     }
1703
1704     if (nCredit == 0 || nCredit > nBalance - nReserveBalance)
1705         return false;
1706
1707     BOOST_FOREACH(PAIRTYPE(const CWalletTx*, unsigned int) pcoin, setCoins)
1708     {
1709         // Attempt to add more inputs
1710         // Only add coins of the same key/address as kernel
1711         if (txNew.vout.size() == 2 && ((pcoin.first->vout[pcoin.second].scriptPubKey == scriptPubKeyKernel || pcoin.first->vout[pcoin.second].scriptPubKey == txNew.vout[1].scriptPubKey))
1712             && pcoin.first->GetHash() != txNew.vin[0].prevout.hash)
1713         {
1714             int64 nTimeWeight = GetWeight((int64)pcoin.first->nTime, (int64)txNew.nTime);
1715
1716             // Stop adding more inputs if already too many inputs
1717             if (txNew.vin.size() >= 100)
1718                 break;
1719             // Stop adding more inputs if value is already pretty significant
1720             if (nCredit > nCombineThreshold)
1721                 break;
1722             // Stop adding inputs if reached reserve limit
1723             if (nCredit + pcoin.first->vout[pcoin.second].nValue > nBalance - nReserveBalance)
1724                 break;
1725             // Do not add additional significant input
1726             if (pcoin.first->vout[pcoin.second].nValue > nCombineThreshold)
1727                 continue;
1728             // Do not add input that is still too young
1729             if (nTimeWeight < nStakeMaxAge)
1730                 continue;
1731
1732             txNew.vin.push_back(CTxIn(pcoin.first->GetHash(), pcoin.second));
1733             nCredit += pcoin.first->vout[pcoin.second].nValue;
1734             vwtxPrev.push_back(pcoin.first);
1735         }
1736     }
1737
1738     // Calculate coin age reward
1739     {
1740         uint64 nCoinAge;
1741         CTxDB txdb("r");
1742         if (!txNew.GetCoinAge(txdb, nCoinAge))
1743             return error("CreateCoinStake : failed to calculate coin age");
1744         nCredit += GetProofOfStakeReward(nCoinAge, nBits, txNew.nTime);
1745     }
1746
1747     int64 nMinFee = 0;
1748     while (true)
1749     {
1750         // Set output amount
1751         if (txNew.vout.size() == 3)
1752         {
1753             txNew.vout[1].nValue = ((nCredit - nMinFee) / 2 / CENT) * CENT;
1754             txNew.vout[2].nValue = nCredit - nMinFee - txNew.vout[1].nValue;
1755         }
1756         else
1757             txNew.vout[1].nValue = nCredit - nMinFee;
1758
1759         // Sign
1760         int nIn = 0;
1761         BOOST_FOREACH(const CWalletTx* pcoin, vwtxPrev)
1762         {
1763             if (!SignSignature(*this, *pcoin, txNew, nIn++))
1764                 return error("CreateCoinStake : failed to sign coinstake");
1765         }
1766
1767         // Limit size
1768         unsigned int nBytes = ::GetSerializeSize(txNew, SER_NETWORK, PROTOCOL_VERSION);
1769         if (nBytes >= MAX_BLOCK_SIZE_GEN/5)
1770             return error("CreateCoinStake : exceeded coinstake size limit");
1771
1772         // Check enough fee is paid
1773         if (nMinFee < txNew.GetMinFee() - MIN_TX_FEE)
1774         {
1775             nMinFee = txNew.GetMinFee() - MIN_TX_FEE;
1776             continue; // try signing again
1777         }
1778         else
1779         {
1780             if (fDebug && GetBoolArg("-printfee"))
1781                 printf("CreateCoinStake : fee for coinstake %s\n", FormatMoney(nMinFee).c_str());
1782             break;
1783         }
1784     }
1785
1786     // Successfully generated coinstake
1787     return true;
1788 }
1789
1790
1791 // Call after CreateTransaction unless you want to abort
1792 bool CWallet::CommitTransaction(CWalletTx& wtxNew, CReserveKey& reservekey)
1793 {
1794     {
1795         LOCK2(cs_main, cs_wallet);
1796         printf("CommitTransaction:\n%s", wtxNew.ToString().c_str());
1797         {
1798             // This is only to keep the database open to defeat the auto-flush for the
1799             // duration of this scope.  This is the only place where this optimization
1800             // maybe makes sense; please don't do it anywhere else.
1801             CWalletDB* pwalletdb = fFileBacked ? new CWalletDB(strWalletFile,"r") : NULL;
1802
1803             // Take key pair from key pool so it won't be used again
1804             reservekey.KeepKey();
1805
1806             // Add tx to wallet, because if it has change it's also ours,
1807             // otherwise just for transaction history.
1808             AddToWallet(wtxNew);
1809
1810             // Mark old coins as spent
1811             set<CWalletTx*> setCoins;
1812             BOOST_FOREACH(const CTxIn& txin, wtxNew.vin)
1813             {
1814                 CWalletTx &coin = mapWallet[txin.prevout.hash];
1815                 coin.BindWallet(this);
1816                 coin.MarkSpent(txin.prevout.n);
1817                 coin.WriteToDisk();
1818                 NotifyTransactionChanged(this, coin.GetHash(), CT_UPDATED);
1819             }
1820
1821             if (fFileBacked)
1822                 delete pwalletdb;
1823         }
1824
1825         // Track how many getdata requests our transaction gets
1826         mapRequestCount[wtxNew.GetHash()] = 0;
1827
1828         // Broadcast
1829         if (!wtxNew.AcceptToMemoryPool())
1830         {
1831             // This must not fail. The transaction has already been signed and recorded.
1832             printf("CommitTransaction() : Error: Transaction not valid");
1833             return false;
1834         }
1835         wtxNew.RelayWalletTransaction();
1836     }
1837     return true;
1838 }
1839
1840
1841
1842
1843 string CWallet::SendMoney(CScript scriptPubKey, int64 nValue, CWalletTx& wtxNew, bool fAskFee)
1844 {
1845     CReserveKey reservekey(this);
1846     int64 nFeeRequired;
1847
1848     if (IsLocked())
1849     {
1850         string strError = _("Error: Wallet locked, unable to create transaction  ");
1851         printf("SendMoney() : %s", strError.c_str());
1852         return strError;
1853     }
1854     if (fWalletUnlockMintOnly)
1855     {
1856         string strError = _("Error: Wallet unlocked for block minting only, unable to create transaction.");
1857         printf("SendMoney() : %s", strError.c_str());
1858         return strError;
1859     }
1860     if (!CreateTransaction(scriptPubKey, nValue, wtxNew, reservekey, nFeeRequired))
1861     {
1862         string strError;
1863         if (nValue + nFeeRequired > GetBalance())
1864             strError = strprintf(_("Error: This transaction requires a transaction fee of at least %s because of its amount, complexity, or use of recently received funds  "), FormatMoney(nFeeRequired).c_str());
1865         else
1866             strError = _("Error: Transaction creation failed  ");
1867         printf("SendMoney() : %s", strError.c_str());
1868         return strError;
1869     }
1870
1871     if (fAskFee && !uiInterface.ThreadSafeAskFee(nFeeRequired, _("Sending...")))
1872         return "ABORTED";
1873
1874     if (!CommitTransaction(wtxNew, reservekey))
1875         return _("Error: The transaction was rejected.  This might happen if some of the coins in your wallet were already spent, such as if you used a copy of wallet.dat and coins were spent in the copy but not marked as spent here.");
1876
1877     return "";
1878 }
1879
1880
1881
1882 string CWallet::SendMoneyToDestination(const CTxDestination& address, int64 nValue, CWalletTx& wtxNew, bool fAskFee)
1883 {
1884     // Check amount
1885     if (nValue <= 0)
1886         return _("Invalid amount");
1887     if (nValue + nTransactionFee > GetBalance())
1888         return _("Insufficient funds");
1889
1890     // Parse Bitcoin address
1891     CScript scriptPubKey;
1892     scriptPubKey.SetDestination(address);
1893
1894     return SendMoney(scriptPubKey, nValue, wtxNew, fAskFee);
1895 }
1896
1897
1898
1899
1900 DBErrors CWallet::LoadWallet(bool& fFirstRunRet)
1901 {
1902     if (!fFileBacked)
1903         return DB_LOAD_OK;
1904     fFirstRunRet = false;
1905     DBErrors nLoadWalletRet = CWalletDB(strWalletFile,"cr+").LoadWallet(this);
1906     if (nLoadWalletRet == DB_NEED_REWRITE)
1907     {
1908         if (CDB::Rewrite(strWalletFile, "\x04pool"))
1909         {
1910             setKeyPool.clear();
1911             // Note: can't top-up keypool here, because wallet is locked.
1912             // User will be prompted to unlock wallet the next operation
1913             // the requires a new key.
1914         }
1915     }
1916
1917     if (nLoadWalletRet != DB_LOAD_OK)
1918         return nLoadWalletRet;
1919     fFirstRunRet = !vchDefaultKey.IsValid();
1920
1921     NewThread(ThreadFlushWalletDB, &strWalletFile);
1922     return DB_LOAD_OK;
1923 }
1924
1925
1926 bool CWallet::SetAddressBookName(const CTxDestination& address, const string& strName)
1927 {
1928     std::map<CTxDestination, std::string>::iterator mi = mapAddressBook.find(address);
1929     mapAddressBook[address] = strName;
1930     NotifyAddressBookChanged(this, address, strName, ::IsMine(*this, address), (mi == mapAddressBook.end()) ? CT_NEW : CT_UPDATED);
1931     if (!fFileBacked)
1932         return false;
1933     return CWalletDB(strWalletFile).WriteName(CBitcoinAddress(address).ToString(), strName);
1934 }
1935
1936 bool CWallet::DelAddressBookName(const CTxDestination& address)
1937 {
1938     mapAddressBook.erase(address);
1939     NotifyAddressBookChanged(this, address, "", ::IsMine(*this, address), CT_DELETED);
1940     if (!fFileBacked)
1941         return false;
1942     return CWalletDB(strWalletFile).EraseName(CBitcoinAddress(address).ToString());
1943 }
1944
1945
1946 void CWallet::PrintWallet(const CBlock& block)
1947 {
1948     {
1949         LOCK(cs_wallet);
1950         if (block.IsProofOfWork() && mapWallet.count(block.vtx[0].GetHash()))
1951         {
1952             CWalletTx& wtx = mapWallet[block.vtx[0].GetHash()];
1953             printf("    mine:  %d  %d  %"PRI64d"", wtx.GetDepthInMainChain(), wtx.GetBlocksToMaturity(), wtx.GetCredit());
1954         }
1955         if (block.IsProofOfStake() && mapWallet.count(block.vtx[1].GetHash()))
1956         {
1957             CWalletTx& wtx = mapWallet[block.vtx[1].GetHash()];
1958             printf("    stake: %d  %d  %"PRI64d"", wtx.GetDepthInMainChain(), wtx.GetBlocksToMaturity(), wtx.GetCredit());
1959          }
1960
1961     }
1962     printf("\n");
1963 }
1964
1965 bool CWallet::GetTransaction(const uint256 &hashTx, CWalletTx& wtx)
1966 {
1967     {
1968         LOCK(cs_wallet);
1969         map<uint256, CWalletTx>::iterator mi = mapWallet.find(hashTx);
1970         if (mi != mapWallet.end())
1971         {
1972             wtx = (*mi).second;
1973             return true;
1974         }
1975     }
1976     return false;
1977 }
1978
1979 bool CWallet::SetDefaultKey(const CPubKey &vchPubKey)
1980 {
1981     if (fFileBacked)
1982     {
1983         if (!CWalletDB(strWalletFile).WriteDefaultKey(vchPubKey))
1984             return false;
1985     }
1986     vchDefaultKey = vchPubKey;
1987     return true;
1988 }
1989
1990 bool GetWalletFile(CWallet* pwallet, string &strWalletFileOut)
1991 {
1992     if (!pwallet->fFileBacked)
1993         return false;
1994     strWalletFileOut = pwallet->strWalletFile;
1995     return true;
1996 }
1997
1998 //
1999 // Mark old keypool keys as used,
2000 // and generate all new keys
2001 //
2002 bool CWallet::NewKeyPool()
2003 {
2004     {
2005         LOCK(cs_wallet);
2006         CWalletDB walletdb(strWalletFile);
2007         BOOST_FOREACH(int64 nIndex, setKeyPool)
2008             walletdb.ErasePool(nIndex);
2009         setKeyPool.clear();
2010
2011         if (IsLocked())
2012             return false;
2013
2014         int64 nKeys = max(GetArg("-keypool", 100), (int64)0);
2015         for (int i = 0; i < nKeys; i++)
2016         {
2017             int64 nIndex = i+1;
2018             walletdb.WritePool(nIndex, CKeyPool(GenerateNewKey()));
2019             setKeyPool.insert(nIndex);
2020         }
2021         printf("CWallet::NewKeyPool wrote %"PRI64d" new keys\n", nKeys);
2022     }
2023     return true;
2024 }
2025
2026 bool CWallet::TopUpKeyPool(unsigned int nSize)
2027 {
2028     {
2029         LOCK(cs_wallet);
2030
2031         if (IsLocked())
2032             return false;
2033
2034         CWalletDB walletdb(strWalletFile);
2035
2036         // Top up key pool
2037         unsigned int nTargetSize;
2038         if (nSize > 0)
2039             nTargetSize = nSize;
2040         else
2041             nTargetSize = max(GetArg("-keypool", 100), 0LL);
2042
2043         while (setKeyPool.size() < (nTargetSize + 1))
2044         {
2045             int64 nEnd = 1;
2046             if (!setKeyPool.empty())
2047                 nEnd = *(--setKeyPool.end()) + 1;
2048             if (!walletdb.WritePool(nEnd, CKeyPool(GenerateNewKey())))
2049                 throw runtime_error("TopUpKeyPool() : writing generated key failed");
2050             setKeyPool.insert(nEnd);
2051             printf("keypool added key %"PRI64d", size=%"PRIszu"\n", nEnd, setKeyPool.size());
2052         }
2053     }
2054     return true;
2055 }
2056
2057 void CWallet::ReserveKeyFromKeyPool(int64& nIndex, CKeyPool& keypool)
2058 {
2059     nIndex = -1;
2060     keypool.vchPubKey = CPubKey();
2061     {
2062         LOCK(cs_wallet);
2063
2064         if (!IsLocked())
2065             TopUpKeyPool();
2066
2067         // Get the oldest key
2068         if(setKeyPool.empty())
2069             return;
2070
2071         CWalletDB walletdb(strWalletFile);
2072
2073         nIndex = *(setKeyPool.begin());
2074         setKeyPool.erase(setKeyPool.begin());
2075         if (!walletdb.ReadPool(nIndex, keypool))
2076             throw runtime_error("ReserveKeyFromKeyPool() : read failed");
2077         if (!HaveKey(keypool.vchPubKey.GetID()))
2078             throw runtime_error("ReserveKeyFromKeyPool() : unknown key in key pool");
2079         assert(keypool.vchPubKey.IsValid());
2080         if (fDebug && GetBoolArg("-printkeypool"))
2081             printf("keypool reserve %"PRI64d"\n", nIndex);
2082     }
2083 }
2084
2085 int64 CWallet::AddReserveKey(const CKeyPool& keypool)
2086 {
2087     {
2088         LOCK2(cs_main, cs_wallet);
2089         CWalletDB walletdb(strWalletFile);
2090
2091         int64 nIndex = 1 + *(--setKeyPool.end());
2092         if (!walletdb.WritePool(nIndex, keypool))
2093             throw runtime_error("AddReserveKey() : writing added key failed");
2094         setKeyPool.insert(nIndex);
2095         return nIndex;
2096     }
2097     return -1;
2098 }
2099
2100 void CWallet::KeepKey(int64 nIndex)
2101 {
2102     // Remove from key pool
2103     if (fFileBacked)
2104     {
2105         CWalletDB walletdb(strWalletFile);
2106         walletdb.ErasePool(nIndex);
2107     }
2108     if(fDebug)
2109         printf("keypool keep %"PRI64d"\n", nIndex);
2110 }
2111
2112 void CWallet::ReturnKey(int64 nIndex)
2113 {
2114     // Return to key pool
2115     {
2116         LOCK(cs_wallet);
2117         setKeyPool.insert(nIndex);
2118     }
2119     if(fDebug)
2120         printf("keypool return %"PRI64d"\n", nIndex);
2121 }
2122
2123 bool CWallet::GetKeyFromPool(CPubKey& result, bool fAllowReuse)
2124 {
2125     int64 nIndex = 0;
2126     CKeyPool keypool;
2127     {
2128         LOCK(cs_wallet);
2129         ReserveKeyFromKeyPool(nIndex, keypool);
2130         if (nIndex == -1)
2131         {
2132             if (fAllowReuse && vchDefaultKey.IsValid())
2133             {
2134                 result = vchDefaultKey;
2135                 return true;
2136             }
2137             if (IsLocked()) return false;
2138             result = GenerateNewKey();
2139             return true;
2140         }
2141         KeepKey(nIndex);
2142         result = keypool.vchPubKey;
2143     }
2144     return true;
2145 }
2146
2147 int64 CWallet::GetOldestKeyPoolTime()
2148 {
2149     int64 nIndex = 0;
2150     CKeyPool keypool;
2151     ReserveKeyFromKeyPool(nIndex, keypool);
2152     if (nIndex == -1)
2153         return GetTime();
2154     ReturnKey(nIndex);
2155     return keypool.nTime;
2156 }
2157
2158 std::map<CTxDestination, int64> CWallet::GetAddressBalances()
2159 {
2160     map<CTxDestination, int64> balances;
2161
2162     {
2163         LOCK(cs_wallet);
2164         BOOST_FOREACH(PAIRTYPE(uint256, CWalletTx) walletEntry, mapWallet)
2165         {
2166             CWalletTx *pcoin = &walletEntry.second;
2167
2168             if (!pcoin->IsFinal() || !pcoin->IsConfirmed())
2169                 continue;
2170
2171             if ((pcoin->IsCoinBase() || pcoin->IsCoinStake()) && pcoin->GetBlocksToMaturity() > 0)
2172                 continue;
2173
2174             int nDepth = pcoin->GetDepthInMainChain();
2175             if (nDepth < (pcoin->IsFromMe() ? 0 : 1))
2176                 continue;
2177
2178             for (unsigned int i = 0; i < pcoin->vout.size(); i++)
2179             {
2180                 CTxDestination addr;
2181                 if (!IsMine(pcoin->vout[i]))
2182                     continue;
2183                 if(!ExtractDestination(pcoin->vout[i].scriptPubKey, addr))
2184                     continue;
2185
2186                 int64 n = pcoin->IsSpent(i) ? 0 : pcoin->vout[i].nValue;
2187
2188                 if (!balances.count(addr))
2189                     balances[addr] = 0;
2190                 balances[addr] += n;
2191             }
2192         }
2193     }
2194
2195     return balances;
2196 }
2197
2198 set< set<CTxDestination> > CWallet::GetAddressGroupings()
2199 {
2200     set< set<CTxDestination> > groupings;
2201     set<CTxDestination> grouping;
2202
2203     BOOST_FOREACH(PAIRTYPE(uint256, CWalletTx) walletEntry, mapWallet)
2204     {
2205         CWalletTx *pcoin = &walletEntry.second;
2206
2207         if (pcoin->vin.size() > 0 && IsMine(pcoin->vin[0]))
2208         {
2209             // group all input addresses with each other
2210             BOOST_FOREACH(CTxIn txin, pcoin->vin)
2211             {
2212                 CTxDestination address;
2213                 if(!ExtractDestination(mapWallet[txin.prevout.hash].vout[txin.prevout.n].scriptPubKey, address))
2214                     continue;
2215                 grouping.insert(address);
2216             }
2217
2218             // group change with input addresses
2219             BOOST_FOREACH(CTxOut txout, pcoin->vout)
2220                 if (IsChange(txout))
2221                 {
2222                     CWalletTx tx = mapWallet[pcoin->vin[0].prevout.hash];
2223                     CTxDestination txoutAddr;
2224                     if(!ExtractDestination(txout.scriptPubKey, txoutAddr))
2225                         continue;
2226                     grouping.insert(txoutAddr);
2227                 }
2228             groupings.insert(grouping);
2229             grouping.clear();
2230         }
2231
2232         // group lone addrs by themselves
2233         for (unsigned int i = 0; i < pcoin->vout.size(); i++)
2234             if (IsMine(pcoin->vout[i]))
2235             {
2236                 CTxDestination address;
2237                 if(!ExtractDestination(pcoin->vout[i].scriptPubKey, address))
2238                     continue;
2239                 grouping.insert(address);
2240                 groupings.insert(grouping);
2241                 grouping.clear();
2242             }
2243     }
2244
2245     set< set<CTxDestination>* > uniqueGroupings; // a set of pointers to groups of addresses
2246     map< CTxDestination, set<CTxDestination>* > setmap;  // map addresses to the unique group containing it
2247     BOOST_FOREACH(set<CTxDestination> grouping, groupings)
2248     {
2249         // make a set of all the groups hit by this new group
2250         set< set<CTxDestination>* > hits;
2251         map< CTxDestination, set<CTxDestination>* >::iterator it;
2252         BOOST_FOREACH(CTxDestination address, grouping)
2253             if ((it = setmap.find(address)) != setmap.end())
2254                 hits.insert((*it).second);
2255
2256         // merge all hit groups into a new single group and delete old groups
2257         set<CTxDestination>* merged = new set<CTxDestination>(grouping);
2258         BOOST_FOREACH(set<CTxDestination>* hit, hits)
2259         {
2260             merged->insert(hit->begin(), hit->end());
2261             uniqueGroupings.erase(hit);
2262             delete hit;
2263         }
2264         uniqueGroupings.insert(merged);
2265
2266         // update setmap
2267         BOOST_FOREACH(CTxDestination element, *merged)
2268             setmap[element] = merged;
2269     }
2270
2271     set< set<CTxDestination> > ret;
2272     BOOST_FOREACH(set<CTxDestination>* uniqueGrouping, uniqueGroupings)
2273     {
2274         ret.insert(*uniqueGrouping);
2275         delete uniqueGrouping;
2276     }
2277
2278     return ret;
2279 }
2280
2281 // ppcoin: check 'spent' consistency between wallet and txindex
2282 // ppcoin: fix wallet spent state according to txindex
2283 void CWallet::FixSpentCoins(int& nMismatchFound, int64& nBalanceInQuestion, bool fCheckOnly)
2284 {
2285     nMismatchFound = 0;
2286     nBalanceInQuestion = 0;
2287
2288     LOCK(cs_wallet);
2289     vector<CWalletTx*> vCoins;
2290     vCoins.reserve(mapWallet.size());
2291     for (map<uint256, CWalletTx>::iterator it = mapWallet.begin(); it != mapWallet.end(); ++it)
2292         vCoins.push_back(&(*it).second);
2293
2294     CTxDB txdb("r");
2295     BOOST_FOREACH(CWalletTx* pcoin, vCoins)
2296     {
2297         // Find the corresponding transaction index
2298         CTxIndex txindex;
2299         if (!txdb.ReadTxIndex(pcoin->GetHash(), txindex))
2300             continue;
2301         for (unsigned int n=0; n < pcoin->vout.size(); n++)
2302         {
2303             if (IsMine(pcoin->vout[n]) && pcoin->IsSpent(n) && (txindex.vSpent.size() <= n || txindex.vSpent[n].IsNull()))
2304             {
2305                 printf("FixSpentCoins found lost coin %sppc %s[%d], %s\n",
2306                     FormatMoney(pcoin->vout[n].nValue).c_str(), pcoin->GetHash().ToString().c_str(), n, fCheckOnly? "repair not attempted" : "repairing");
2307                 nMismatchFound++;
2308                 nBalanceInQuestion += pcoin->vout[n].nValue;
2309                 if (!fCheckOnly)
2310                 {
2311                     pcoin->MarkUnspent(n);
2312                     pcoin->WriteToDisk();
2313                 }
2314             }
2315             else if (IsMine(pcoin->vout[n]) && !pcoin->IsSpent(n) && (txindex.vSpent.size() > n && !txindex.vSpent[n].IsNull()))
2316             {
2317                 printf("FixSpentCoins found spent coin %sppc %s[%d], %s\n",
2318                     FormatMoney(pcoin->vout[n].nValue).c_str(), pcoin->GetHash().ToString().c_str(), n, fCheckOnly? "repair not attempted" : "repairing");
2319                 nMismatchFound++;
2320                 nBalanceInQuestion += pcoin->vout[n].nValue;
2321                 if (!fCheckOnly)
2322                 {
2323                     pcoin->MarkSpent(n);
2324                     pcoin->WriteToDisk();
2325                 }
2326             }
2327         }
2328     }
2329 }
2330
2331 // ppcoin: disable transaction (only for coinstake)
2332 void CWallet::DisableTransaction(const CTransaction &tx)
2333 {
2334     if (!tx.IsCoinStake() || !IsFromMe(tx))
2335         return; // only disconnecting coinstake requires marking input unspent
2336
2337     LOCK(cs_wallet);
2338     BOOST_FOREACH(const CTxIn& txin, tx.vin)
2339     {
2340         map<uint256, CWalletTx>::iterator mi = mapWallet.find(txin.prevout.hash);
2341         if (mi != mapWallet.end())
2342         {
2343             CWalletTx& prev = (*mi).second;
2344             if (txin.prevout.n < prev.vout.size() && IsMine(prev.vout[txin.prevout.n]))
2345             {
2346                 prev.MarkUnspent(txin.prevout.n);
2347                 prev.WriteToDisk();
2348             }
2349         }
2350     }
2351 }
2352
2353 CPubKey CReserveKey::GetReservedKey()
2354 {
2355     if (nIndex == -1)
2356     {
2357         CKeyPool keypool;
2358         pwallet->ReserveKeyFromKeyPool(nIndex, keypool);
2359         if (nIndex != -1)
2360             vchPubKey = keypool.vchPubKey;
2361         else
2362         {
2363             printf("CReserveKey::GetReservedKey(): Warning: Using default key instead of a new key, top up your keypool!");
2364             vchPubKey = pwallet->vchDefaultKey;
2365         }
2366     }
2367     assert(vchPubKey.IsValid());
2368     return vchPubKey;
2369 }
2370
2371 void CReserveKey::KeepKey()
2372 {
2373     if (nIndex != -1)
2374         pwallet->KeepKey(nIndex);
2375     nIndex = -1;
2376     vchPubKey = CPubKey();
2377 }
2378
2379 void CReserveKey::ReturnKey()
2380 {
2381     if (nIndex != -1)
2382         pwallet->ReturnKey(nIndex);
2383     nIndex = -1;
2384     vchPubKey = CPubKey();
2385 }
2386
2387 void CWallet::GetAllReserveKeys(set<CKeyID>& setAddress) const
2388 {
2389     setAddress.clear();
2390
2391     CWalletDB walletdb(strWalletFile);
2392
2393     LOCK2(cs_main, cs_wallet);
2394     BOOST_FOREACH(const int64& id, setKeyPool)
2395     {
2396         CKeyPool keypool;
2397         if (!walletdb.ReadPool(id, keypool))
2398             throw runtime_error("GetAllReserveKeyHashes() : read failed");
2399         assert(keypool.vchPubKey.IsValid());
2400         CKeyID keyID = keypool.vchPubKey.GetID();
2401         if (!HaveKey(keyID))
2402             throw runtime_error("GetAllReserveKeyHashes() : unknown key in key pool");
2403         setAddress.insert(keyID);
2404     }
2405 }
2406
2407 void CWallet::UpdatedTransaction(const uint256 &hashTx)
2408 {
2409     {
2410         LOCK(cs_wallet);
2411         // Only notify UI if this transaction is in this wallet
2412         map<uint256, CWalletTx>::const_iterator mi = mapWallet.find(hashTx);
2413         if (mi != mapWallet.end())
2414             NotifyTransactionChanged(this, hashTx, CT_UPDATED);
2415     }
2416 }
2417
2418 void CWallet::GetKeyBirthTimes(std::map<CKeyID, int64> &mapKeyBirth) const {
2419     mapKeyBirth.clear();
2420
2421     // get birth times for keys with metadata
2422     for (std::map<CKeyID, CKeyMetadata>::const_iterator it = mapKeyMetadata.begin(); it != mapKeyMetadata.end(); it++)
2423         if (it->second.nCreateTime)
2424             mapKeyBirth[it->first] = it->second.nCreateTime;
2425
2426     // map in which we'll infer heights of other keys
2427     CBlockIndex *pindexMax = FindBlockByHeight(std::max(0, nBestHeight - 144)); // the tip can be reorganised; use a 144-block safety margin
2428     std::map<CKeyID, CBlockIndex*> mapKeyFirstBlock;
2429     std::set<CKeyID> setKeys;
2430     GetKeys(setKeys);
2431     BOOST_FOREACH(const CKeyID &keyid, setKeys) {
2432         if (mapKeyBirth.count(keyid) == 0)
2433             mapKeyFirstBlock[keyid] = pindexMax;
2434     }
2435     setKeys.clear();
2436
2437     // if there are no such keys, we're done
2438     if (mapKeyFirstBlock.empty())
2439         return;
2440
2441     // find first block that affects those keys, if there are any left
2442     std::vector<CKeyID> vAffected;
2443     for (std::map<uint256, CWalletTx>::const_iterator it = mapWallet.begin(); it != mapWallet.end(); it++) {
2444         // iterate over all wallet transactions...
2445         const CWalletTx &wtx = (*it).second;
2446         std::map<uint256, CBlockIndex*>::const_iterator blit = mapBlockIndex.find(wtx.hashBlock);
2447         if (blit != mapBlockIndex.end() && blit->second->IsInMainChain()) {
2448             // ... which are already in a block
2449             int nHeight = blit->second->nHeight;
2450             BOOST_FOREACH(const CTxOut &txout, wtx.vout) {
2451                 // iterate over all their outputs
2452                 ::ExtractAffectedKeys(*this, txout.scriptPubKey, vAffected);
2453                 BOOST_FOREACH(const CKeyID &keyid, vAffected) {
2454                     // ... and all their affected keys
2455                     std::map<CKeyID, CBlockIndex*>::iterator rit = mapKeyFirstBlock.find(keyid);
2456                     if (rit != mapKeyFirstBlock.end() && nHeight < rit->second->nHeight)
2457                         rit->second = blit->second;
2458                 }
2459                 vAffected.clear();
2460             }
2461         }
2462     }
2463
2464     // Extract block timestamps for those keys
2465     for (std::map<CKeyID, CBlockIndex*>::const_iterator it = mapKeyFirstBlock.begin(); it != mapKeyFirstBlock.end(); it++)
2466         mapKeyBirth[it->first] = it->second->nTime - 7200; // block times can be 2h off
2467 }