X-Git-Url: https://git.donarmstrong.com/?a=blobdiff_plain;f=flowdata.cpp;h=b2e856c28e5c939a00102e19d34a97799c11ae08;hb=70491a12902e89b85cfa6b44a7b7fbe066ee2ac1;hp=5dc7dc3e6c780171f1ee5cacdb1d766864f18a18;hpb=c85db0a4be3a1f8037a71a23ca73f9762184e28a;p=mothur.git

diff --git a/flowdata.cpp b/flowdata.cpp
index 5dc7dc3..b2e856c 100644
--- a/flowdata.cpp
+++ b/flowdata.cpp
@@ -50,7 +50,7 @@ bool FlowData::getNext(ifstream& flowFile){
             translateFlow();
             m->gobble(flowFile);
 		}
-            
+           
 		if(flowFile){	return 1;	}
 		else		{	return 0;	}
 	}
@@ -86,16 +86,18 @@ string FlowData::getSequenceName(ifstream& flowFile) {
 void FlowData::updateEndFlow(){
 	try{
 		
+        if (baseFlow.length() > 4) { return; }
+        
 		//int currLength = 0;
 		float maxIntensity = (float) maxHomoP + 0.49;
 		
 		int deadSpot = 0;
-				
+			
 		while(deadSpot < endFlow){
 			int signal = 0;
 			int noise = 0;
 			
-			for(int i=0;i<4;i++){
+			for(int i=0;i<baseFlow.length();i++){
 				float intensity = flowData[i + deadSpot];
 				if(intensity > signalIntensity){
 					signal++;
@@ -110,7 +112,7 @@ void FlowData::updateEndFlow(){
 				break;
 			}
 		
-			deadSpot += 4;
+			deadSpot += baseFlow.length();
 		}
 		endFlow = deadSpot;
 
@@ -122,27 +124,49 @@ void FlowData::updateEndFlow(){
 }
 
 //**********************************************************************************************************************
-
+//TATGCT
+//1 0 0 0 0 1
+//then the second positive flow is for a T, but you saw a T between the last and previous flow adn it wasn't positive, so something is missing
+//Becomes TNT
 void FlowData::translateFlow(){
-	
 	try{
-		sequence = "";
-		for(int i=0;i<endFlow;i++){
+        sequence = "";
+        set<char> charInMiddle;
+        int oldspot = -1;
+        bool updateOld = false;
+        
+        for(int i=0;i<endFlow;i++){
 			int intensity = (int)(flowData[i] + 0.5);
-			char base = baseFlow[i % 4];
+			char base = baseFlow[i % baseFlow.length()];
+            
+            if (intensity == 0) { //are we in the middle
+                if (oldspot != -1) { charInMiddle.insert(base); }
+            }else if (intensity >= 1) {
+                if (oldspot == -1) { updateOld = true;  }
+                else {  //check for bases inbetween two 1's
+                    if (charInMiddle.count(base) != 0) { //we want to covert to an N
+                        sequence = sequence.substr(0, oldspot+1);
+                        sequence += 'N';
+                    }
+                    updateOld = true;
+                    charInMiddle.clear();
+                }
+            }
 			
 			for(int j=0;j<intensity;j++){
 				sequence += base;
 			}
+            
+            if (updateOld) { oldspot = sequence.length()-1;  updateOld = false; }
 		}
-
+        
 		if(sequence.size() > 4){
 			sequence = sequence.substr(4);
 		}
 		else{
 			sequence = "NNNN";
 		}
-	}
+    }
 	catch(exception& e) {
 		m->errorOut(e, "FlowData", "translateFlow");
 		exit(1);