memcached setting for streaming

Author: adifiore

SSRtest/ModifiedReact.js

@@ -2387,7 +2387,6 @@ var ReactDOMServerRenderer = function () {
  out += outCopy.substring(bookmark, outCopy.length);
  }
  } else {
- // console.log(out.length, streamingStart);
  streamingStart.sliceStartCount += out.length;
  }
  return out;
@@ -2698,15 +2697,6 @@ var ReactMarkupReadableStream = function (_Readable) {
  this.streamingStart,
  this.memLife);
  this.push(readOutput);
- // this.push(
- // this.partialRenderer.read(
- // size,
- // this.cache,
- // true,
- // this.streamingStart,
- // this.memLife
- // )
- // );
  } catch (err) {
  this.emit('error', err);
  }
@@ -2736,7 +2726,7 @@ function renderToNodeStream(element, cache, streamingStart, memLife=0) {
  * such as data-react-id that React uses internally.
  * See https://reactjs.org/docs/react-dom-stream.html#rendertostaticnodestream
  */
-function renderToStaticNodeStream(element, cache, streamingStart, memLife) {
+function renderToStaticNodeStream(element, cache, streamingStart, memLife=0) {
  return new ReactMarkupReadableStream(element, true, cache, streamingStart, memLife);
 }
 

SSRtest/src/server/cacheStream.js

@@ -2,7 +2,7 @@ import { Transform } from "stream";
 import { create } from "domain";
 import { lstat } from "fs";
 
-const createCacheStream = (cache, streamingStart) => {
+const createCacheStream = (cache, streamingStart, memLife=0) => {
  const bufferedChunks = [];
  return new Transform({
  // transform() is called with each chunk of data
@@ -43,11 +43,15 @@ const createCacheStream = (cache, streamingStart) => {
  else tagStack.pop();
  }
  } while (tagStack.length !== 0);
- //console.log(html.slice(streamingStart[component], tagEnd));
  // cache component by slicing 'html'
- cache.set(component, html.slice(streamingStart[component], tagEnd));
+ if (memLife) {
+ cache.set(component, html.slice(streamingStart[component], tagEnd), memLife, (err) => {
+ if(err) console.log(err)
+ });
+ } else {
+ cache.set(component, html.slice(streamingStart[component], tagEnd));
+ }
  }
- //console.log("to be saved:", bufferedChunks.join(""));
  cb();
  }
  });

SSRtest/src/server/index.js

@@ -31,7 +31,7 @@ const streamingStart = {
 export default ({ clientStats }) => async (req, res) => {
  // Need To Come back To If Statement
  if(true){
- const cacheStream = createCacheStream(cache, streamingStart);
+ const cacheStream = createCacheStream(cache, streamingStart, 30);
  cacheStream.pipe(res);
  cacheStream.write(htmlStart);
 
@@ -45,7 +45,7 @@ export default ({ clientStats }) => async (req, res) => {
  const app = <App />;
  const start_cached = process.hrtime();
 
- const appString = await ReactCC.renderToStaticMarkup(app, cache, 30);
+ const appString = await ReactCC.renderToString(app, cache, 30);
  const end_cached = process.hrtime(start_cached);
  console.info(
  "Cached render time: %ds %dms",

SSRtest/src/shared/List.js

@@ -12,7 +12,7 @@ export default class List extends Component {
  let bunchOfProducts = [];
  const templatizedProps = ["name", "description", "price"];
  for (let i=0; i<100; i++) {
- bunchOfProducts.push(<ProductInfo key={i} name={`Thing ${i}`} description="This product is awesome!" price={i * 10} nonTemplatized="THIS TEXT SHOULD NEVER CHANGE" cache templatized={templatizedProps} />);
+ bunchOfProducts.push(<ProductInfo key={i} name={`Thing ${i}`} description="This product is awesome!" price={i * 10} nonTemplatized="THIS TEXT SHOULD NEVER CHANGE" cache templatized={templatizedProps}/>);
  }
  return (
  <div>